com.aspc.DBObj.Internal

Interface StatementBatch

All Known Implementing Classes:

StatementBatchV10, StatementBatchV9

public interface 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

Modifier and Type	Field and Description
static java.lang.String	SINGLE_STATEMENTS single statements only
static java.util.concurrent.atomic.AtomicLong	STATEMENTS_WRITTEN How many statements have been written in total ?

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)
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

Field Detail

SINGLE_STATEMENTS

static final java.lang.String SINGLE_STATEMENTS

single statements only

See Also:

Constant Field Values

STATEMENTS_WRITTEN

static final java.util.concurrent.atomic.AtomicLong STATEMENTS_WRITTEN

How many statements have been written in total ?

Method Detail

supportWildCardCopyToJournal

@CheckReturnValue
boolean supportWildCardCopyToJournal()

do we support wild card copy

Returns:

true if supported.

supportPreparedInsert

@CheckReturnValue
boolean supportPreparedInsert()

do we support prepared insert

Returns:

true if supported.

preparedInsert

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

prepared statement

Parameters:

statement - the statement

args - the arguments

setTransHeader

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

set the transaction header

Parameters:

tg - the transaction group

realLogin - the real login

reason - the reason

getTransNr

@Nonnegative
 @CheckReturnValue
long getTransNr()

the transaction number

Returns:

the transaction number

getTransMS

@Nonnegative
 @CheckReturnValue
long getTransMS()

the transaction milliseconds

Returns:

the transaction milliseconds

getRecentLink

@Nonnegative
 @CheckReturnValue
java.lang.String getRecentLink(DBField field)

Parameters:

field - The field

Returns:

the value

setRecentLink

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

Parameters:

field - The field

txt - the text

deleteField

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

Parameters:

table - the table

row - the row to use

fieldId - the field

deleteCriteria

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

delete a criteria from a table.

Parameters:

table - the table.

criteria - the criteria

deleteCriteriaPost

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

delete a criteria from a table.

Parameters:

table - the table.

criteria - the criteria

deleteRow

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

Parameters:

table - the table

row - the row to use

addSystemTransaction

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

Parameters:

systemCode - the system code

addInsert

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

Parameters:

statement - the statement

correctJournal

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

we know the journal is wrong for this row.

Parameters:

rowUID - the row to check

rootClass - root class

addRowTrans

void addRowTrans(@Nonnull
                 RowTrans rt)

add a row transaction

Parameters:

rt - the row transaction

hasSQLEscape

@CheckReturnValue
boolean hasSQLEscape()

Returns:

the value

writeFieldSQL

int writeFieldSQL(DBObject obj,
                  DBField field,
                  java.lang.Object current,
                  java.lang.Object previous,
                  int startSeq,
                  int pos)
           throws java.lang.Exception

create a list of segments

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

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

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

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

Parameters:

dbClass - the class

rowKey - the row

field - The field

copyFieldToTrans

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

copy the field into the transaction table.

Parameters:

dbClass - the class

rowKey - the row

fieldID - The field ID

addUpdate

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

Parameters:

statement - the statement

addPreStatements

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

Parameters:

statement - the statement

beginTransaction

void beginTransaction()
               throws java.lang.Exception

Throws:

java.lang.Exception - Exception A serious problem

execute

void execute()
      throws java.lang.Exception

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

Throws:

java.lang.Exception - Exception A serious problem

postSave

void postSave()

post save