class OnlineBackupTest1.DatabaseActions
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private int |
action |
private static int |
COMMIT |
private java.sql.Connection |
conn |
static int |
CREATEDROPS |
static int |
DMLACTIONS |
private static int |
OPENTX |
private static int |
ROLLBACK |
private boolean |
stopActivity |
Constructor and Description |
---|
DatabaseActions(java.sql.Connection conn) |
DatabaseActions(int action,
java.sql.Connection conn) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
createTable(java.lang.String tableName) |
(package private) void |
endTransaction(int txStatus)
commit/rollback the transaction.
|
(package private) void |
endUnloggedAction(java.lang.String tableName)
end an Unlogged operation, commit the transaction.
|
(package private) void |
insert(java.lang.String tableName,
int rowCount,
int txStatus,
int commitCount)
Insert some rows into the specified table.
|
(package private) void |
performCreateDropTables()
Create and Drop some tables.
|
(package private) void |
performDmlActions() |
void |
run()
implementation of run() method in the Runnable interface, which
is invoked when a thread is started using this class object.
|
(package private) void |
select(java.lang.String tableName) |
(package private) void |
startUnloggedAction(java.lang.String tableName)
start an Unlogged operation, but don't commit the transaction.
|
void |
stopActivity()
stops any actions that are looping on a differt threads.
|
(package private) void |
update(java.lang.String tableName,
int rowCount,
int txStatus,
int commitCount)
update some rows in the table.
|
public static final int DMLACTIONS
public static final int CREATEDROPS
private static final int COMMIT
private static final int ROLLBACK
private static final int OPENTX
private int action
private volatile boolean stopActivity
private java.sql.Connection conn
DatabaseActions(java.sql.Connection conn)
DatabaseActions(int action, java.sql.Connection conn)
public void stopActivity()
public void run()
Performs DML ot DDL actions.
run
in interface java.lang.Runnable
void performDmlActions() throws java.sql.SQLException
java.sql.SQLException
void startUnloggedAction(java.lang.String tableName) throws java.sql.SQLException
tableName
- name of the table to start the unlogged operation.java.sql.SQLException
- if any database exception occurs.void endUnloggedAction(java.lang.String tableName) throws java.sql.SQLException
tableName
- name of the table to end unlogged operation.java.sql.SQLException
- if any database exception occurs.void performCreateDropTables() throws java.sql.SQLException
java.sql.SQLException
- if any database exception occurs.void insert(java.lang.String tableName, int rowCount, int txStatus, int commitCount) throws java.sql.SQLException
tableName
- name of the table that rows are inserted.rowCount
- Number of rows to Insert.txStatus
- Transacton status commit/rollback/open.commitCount
- After how many inserts commit/rollbacku should happen.java.sql.SQLException
- if any database exception occurs.void endTransaction(int txStatus) throws java.sql.SQLException
txStatus
- Transacton status commit/rollback/open.java.sql.SQLException
- if any database exception occurs.void update(java.lang.String tableName, int rowCount, int txStatus, int commitCount) throws java.sql.SQLException
tableName
- name of the table that rows are updates.rowCount
- Number of rows to update.txStatus
- Transacton status commit/rollback/open.commitCount
- After how many updates commit/rollback should
happen.java.sql.SQLException
- if any database exception occurs.void select(java.lang.String tableName) throws java.sql.SQLException
java.sql.SQLException
void createTable(java.lang.String tableName) throws java.sql.SQLException
java.sql.SQLException
Apache Derby V10.13 Internals - Copyright © 2004,2016 The Apache Software Foundation. All Rights Reserved.