com.aspc.DBObj.Internal.impl

Class StatementBatchV9

java.lang.Object

com.aspc.DBObj.Internal.impl.StatementBatchV9

All Implemented Interfaces:

StatementBatch

public class StatementBatchV9
extends java.lang.Object
implements StatementBatch

Batch all database modification requests together. THREAD MODE: SINGLE-THREADED one per save.

Since:

January 8, 2002, 12:31 PM

Author:

Nigel Leck

Field Summary

Fields inherited from interface com.aspc.DBObj.Internal.StatementBatch

SINGLE_STATEMENTS, STATEMENTS_WRITTEN

Constructor Summary

Constructors

Constructor and Description
StatementBatchV9(VirtualDB vDB, long transNr)

Method Summary

Modifier and Type	Method and Description
void	addInsert(java.lang.String statement)
void	addPreStatements(java.lang.String statement)
void	addRowTrans(RowTrans rt) add a row transaction
void	addSystemTransaction(java.lang.String systemCode)
void	addUpdate(java.lang.String statement)
void	beginTransaction()
void	copyFieldToTrans(DBClass dbClass, java.lang.Long rowKey, DBField field) copy the field into the transaction table.
void	copyFieldToTrans(DBClass dbClass, java.lang.Long rowKey, java.lang.String fieldID) copy the field into the transaction table.
void	correctJournal(long rowUID, DBClass rootClass) we know the journal is wrong for this row.
void	deleteCriteria(java.lang.String table, java.lang.String criteria) delete a criteria from a table.
void	deleteCriteriaPost(java.lang.String table, java.lang.String criteria) delete a criteria from a table.
void	deleteField(java.lang.String table, long row, GlobalId fieldId)
void	deleteRow(java.lang.String table, long row)
void	execute() If the transaction is not handled externally then I'll handle it.
int	generateFieldSegment(DBObject obj, DBField field, java.lang.Object current, java.lang.Object previous, int startSeq, java.util.ArrayList segmentList, int pos) create a list of segments
java.lang.String	getRecentLink(DBField field)
long	getTransMS() the transaction milliseconds
long	getTransNr() the transaction number
boolean	hasSQLEscape()
void	postSave() post save
void	preparedInsert(java.lang.String statement, java.lang.Object[] args) prepared statement
void	setRecentLink(DBField field, java.lang.String txt)
void	setTransHeader(TransGroup tg, Login realLogin, java.lang.String reason) set the transaction header
boolean	supportPreparedInsert() do we support prepared insert
boolean	supportWildCardCopyToJournal() do we support wild card copy
int	writeFieldSQL(DBObject obj, DBField field, java.lang.Object current, java.lang.Object previous, int startSeq, int pos) create a list of segments

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatementBatchV9

public StatementBatchV9(@Nonnull
                        VirtualDB vDB,
                        long transNr)
                 throws java.lang.Exception

Parameters:

vDB - the layer

transNr - the transaction number

Throws:

java.lang.Exception - Exception A serious problem

Method Detail

setTransHeader

public void setTransHeader(@Nullable
                           TransGroup tg,
                           Login realLogin,
                           java.lang.String reason)

set the transaction header

Specified by:

setTransHeader in interface StatementBatch

Parameters:

tg - the transaction group

realLogin - the real login

reason - the reason

getTransNr

@Nonnegative
 @CheckReturnValue
public long getTransNr()

the transaction number

Specified by:

getTransNr in interface StatementBatch

Returns:

the transaction number

getTransMS

@Nonnegative
 @CheckReturnValue
public long getTransMS()

the transaction milliseconds

Specified by:

getTransMS in interface StatementBatch

Returns:

the transaction milliseconds

getRecentLink

@CheckReturnValue
public java.lang.String getRecentLink(@Nonnull
                                                        DBField field)

Specified by:

getRecentLink in interface StatementBatch

Parameters:

field - The field

Returns:

the value

setRecentLink

public void setRecentLink(@Nonnull
                          DBField field,
                          @Nonnull
                          java.lang.String txt)

Specified by:

setRecentLink in interface StatementBatch

Parameters:

field - The field

txt - the text

deleteField

public void deleteField(@Nonnull
                        java.lang.String table,
                        long row,
                        @Nonnull
                        GlobalId fieldId)

Specified by:

deleteField in interface StatementBatch

Parameters:

table - the table

row - the row to use

fieldId - the field

deleteCriteria

public void deleteCriteria(@Nonnull
                           java.lang.String table,
                           @Nonnull
                           java.lang.String criteria)

delete a criteria from a table.

Specified by:

deleteCriteria in interface StatementBatch

Parameters:

table - the table.

criteria - the criteria

deleteCriteriaPost

public void deleteCriteriaPost(@Nonnull
                               java.lang.String table,
                               @Nonnull
                               java.lang.String criteria)

delete a criteria from a table.

Specified by:

deleteCriteriaPost in interface StatementBatch

Parameters:

table - the table.

criteria - the criteria

deleteRow

public void deleteRow(@Nonnull
                      java.lang.String table,
                      long row)

Specified by:

deleteRow in interface StatementBatch

Parameters:

table - the table

row - the row to use

addSystemTransaction

public void addSystemTransaction(@Nonnull
                                 java.lang.String systemCode)

Specified by:

addSystemTransaction in interface StatementBatch

Parameters:

systemCode - the code

addInsert

public void addInsert(@Nonnull
                      java.lang.String statement)

Specified by:

addInsert in interface StatementBatch

Parameters:

statement - the statement

addRowTrans

public void addRowTrans(@Nonnull
                        RowTrans rt)

add a row transaction

Specified by:

addRowTrans in interface StatementBatch

Parameters:

rt - the row transaction

hasSQLEscape

@CheckReturnValue
public boolean hasSQLEscape()

Specified by:

hasSQLEscape in interface StatementBatch

Returns:

the value

writeFieldSQL

public int writeFieldSQL(@Nonnull
                         DBObject obj,
                         @Nonnull
                         DBField field,
                         @Nullable
                         java.lang.Object current,
                         @Nullable
                         java.lang.Object previous,
                         @Nonnegative
                         int startSeq,
                         @Nonnegative
                         int pos)
                  throws java.lang.Exception

create a list of segments

Specified by:

writeFieldSQL in interface StatementBatch

Parameters:

obj - The base object

field - the field to generate segments for

current - The current value

previous - The previous value

startSeq - The starting sequence number

pos - the position

Returns:

the max seq number used

Throws:

java.lang.Exception - A serious problem

generateFieldSegment

public int generateFieldSegment(@Nonnull
                                DBObject obj,
                                @Nonnull
                                DBField field,
                                @Nullable
                                java.lang.Object current,
                                @Nullable
                                java.lang.Object previous,
                                @Nonnegative
                                int startSeq,
                                @Nonnull
                                java.util.ArrayList segmentList,
                                @Nonnegative
                                int pos)
                         throws java.lang.Exception

create a list of segments

Specified by:

generateFieldSegment in interface StatementBatch

Parameters:

obj - The base object

field - the field to generate segments for

current - The current value

previous - The previous value

startSeq - The starting sequence number

segmentList - The list of Segments

pos - the position

Returns:

the max seq number used

Throws:

java.lang.Exception - A serious problem

copyFieldToTrans

public void copyFieldToTrans(@Nonnull
                             DBClass dbClass,
                             @Nonnull
                             java.lang.Long rowKey,
                             @Nonnull
                             DBField field)

copy the field into the transaction table.

Specified by:

copyFieldToTrans in interface StatementBatch

Parameters:

dbClass - the class

rowKey - the row

field - The field

copyFieldToTrans

public void copyFieldToTrans(@Nonnull
                             DBClass dbClass,
                             @Nonnull
                             java.lang.Long rowKey,
                             @Nonnull
                             java.lang.String fieldID)

copy the field into the transaction table.

Specified by:

copyFieldToTrans in interface StatementBatch

Parameters:

dbClass - the class

rowKey - the row

fieldID - The field ID

addUpdate

public void addUpdate(@Nonnull
                      java.lang.String statement)

Specified by:

addUpdate in interface StatementBatch

Parameters:

statement - the statement

addPreStatements

public void addPreStatements(@Nonnull
                             java.lang.String statement)

Specified by:

addPreStatements in interface StatementBatch

Parameters:

statement - the statement

beginTransaction

public void beginTransaction()
                      throws java.lang.Exception

Specified by:

beginTransaction in interface StatementBatch

Throws:

java.lang.Exception - Exception A serious problem

execute

public void execute()
             throws java.lang.Exception

If the transaction is not handled externally then I'll handle it.

Specified by:

execute in interface StatementBatch

Throws:

java.lang.Exception - Exception A serious problem

postSave

public void postSave()

post save

Specified by:

postSave in interface StatementBatch

correctJournal

public void correctJournal(@Nonnegative
                           long rowUID,
                           @Nonnull
                           DBClass rootClass)

we know the journal is wrong for this row.

Specified by:

correctJournal in interface StatementBatch

Parameters:

rowUID - the row to check

rootClass - root class

supportWildCardCopyToJournal

@CheckReturnValue
public boolean supportWildCardCopyToJournal()

do we support wild card copy

Specified by:

supportWildCardCopyToJournal in interface StatementBatch

Returns:

true if supported.

supportPreparedInsert

@CheckReturnValue
public boolean supportPreparedInsert()

do we support prepared insert

Specified by:

supportPreparedInsert in interface StatementBatch

Returns:

true if supported.

preparedInsert

public void preparedInsert(@Nonnull
                           java.lang.String statement,
                           @Nonnull
                           java.lang.Object[] args)

prepared statement

Specified by:

preparedInsert in interface StatementBatch

Parameters:

statement - the statement

args - the arguments