本文整理汇总了Java中org.hsqldb.RowAction类的典型用法代码示例。如果您正苦于以下问题：Java RowAction类的具体用法？Java RowAction怎么用？Java RowAction使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RowAction类属于org.hsqldb包，在下文中一共展示了RowAction类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
remove(row);
break;
case RowAction.ACTION_INSERT :
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELEETE
remove(row);
break;
case RowAction.ACTION_DELETE_FINAL :
throw Error.runtimeError(ErrorCode.U_S0500, "RowStore");
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:23，代码来源:RowStoreAVLHybrid.java
示例2: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
Object[] data = row.getData();
switch (changeAction) {
case RowAction.ACTION_DELETE :
database.logger.writeDeleteStatement(session, (Table) table,
data);
break;
case RowAction.ACTION_INSERT :
database.logger.writeInsertStatement(session, row,
(Table) table);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
break;
case RowAction.ACTION_DELETE_FINAL :
throw Error.runtimeError(ErrorCode.U_S0500, "RowStore");
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:27，代码来源:RowStoreAVLMemory.java
示例3: rollbackRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void rollbackRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
if (txModel == TransactionManager.LOCKS) {
((RowAVL) row).setNewNodes(this);
indexRow(session, row);
}
break;
case RowAction.ACTION_INSERT :
delete(session, row);
remove(row);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
remove(row);
break;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:25，代码来源:RowStoreAVLMemory.java
示例4: getNewCachedObject
import org.hsqldb.RowAction; //导入依赖的package包/类
public CachedObject getNewCachedObject(Session session,
Object object)
{
Row row = new RowAVL(table, (Object[]) object);
if (session != null) {
RowAction.addAction(session, RowAction.ACTION_INSERT, table, row);
}
int id = rowIdSequence++;
row.setPos(id);
rowIdMap.put(id, row);
return row;
}
开发者ID:s-store，项目名称:sstore-soft，代码行数:18，代码来源:RowStoreAVLMemory.java
示例5: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
remove(row);
break;
case RowAction.ACTION_INSERT :
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELEETE
remove(row);
break;
case RowAction.ACTION_DELETE_FINAL :
delete(session, row);
remove(row);
break;
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:25，代码来源:RowStoreAVLHybrid.java
示例6: getNewCachedObject
import org.hsqldb.RowAction; //导入依赖的package包/类
public CachedObject getNewCachedObject(Session session, Object object,
boolean tx) {
int id;
synchronized (this) {
id = rowIdSequence++;
}
Row row = new RowAVL(table, (Object[]) object, id, this);
if (tx) {
RowAction action = new RowAction(session, table,
RowAction.ACTION_INSERT, row,
null);
row.rowAction = action;
}
return row;
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:22，代码来源:RowStoreAVLMemory.java
示例7: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
remove(row.getPos());
break;
case RowAction.ACTION_INSERT :
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELEETE
remove(row.getPos());
break;
case RowAction.ACTION_DELETE_FINAL :
delete(session, row);
break;
}
}
开发者ID:RabadanLab，项目名称:Pegasus，代码行数:24，代码来源:RowStoreAVLHybrid.java
示例8: rollbackRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void rollbackRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
row = (Row) get(row, true);
((RowAVL) row).setNewNodes(this);
row.keepInMemory(false);
indexRow(session, row);
break;
case RowAction.ACTION_INSERT :
delete(session, row);
remove(row.getPos());
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELEETE
remove(row.getPos());
break;
}
}
开发者ID:RabadanLab，项目名称:Pegasus，代码行数:26，代码来源:RowStoreAVLHybrid.java
示例9: getNewCachedObject
import org.hsqldb.RowAction; //导入依赖的package包/类
public CachedObject getNewCachedObject(Session session, Object object,
boolean tx) {
Row row = new RowAVLDisk(table, (Object[]) object, this);
add(row);
if (tx) {
RowAction action = new RowAction(session, table,
RowAction.ACTION_INSERT, row,
null);
row.rowAction = action;
}
return row;
}
开发者ID:RabadanLab，项目名称:Pegasus，代码行数:18，代码来源:RowStoreAVLDisk.java
示例10: rollbackRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void rollbackRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
row = (Row) get(row, true);
((RowAVL) row).setNewNodes(this);
row.keepInMemory(false);
indexRow(session, row);
break;
case RowAction.ACTION_INSERT :
delete(session, row);
remove(row);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELEETE
remove(row);
break;
}
}
开发者ID:topahl，项目名称:StoryBear，代码行数:26，代码来源:RowStoreAVLHybrid.java
示例11: getNewCachedObject
import org.hsqldb.RowAction; //导入依赖的package包/类
public CachedObject getNewCachedObject(Session session, Object object,
boolean tx) {
int id = rowIdSequence.getAndIncrement();
Row row = new RowAVL(table, (Object[]) object, id, this);
if (tx) {
RowAction.addInsertAction(session, table, row);
}
return row;
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:13，代码来源:RowStoreAVLMemory.java
示例12: postCommitAction
import org.hsqldb.RowAction; //导入依赖的package包/类
public void postCommitAction(Session session, RowAction action) {
if (action.getType() == RowAction.ACTION_DELETE_FINAL
&& !action.isDeleteComplete()) {
action.setDeleteComplete();
Row row = action.getRow();
delete(session, row);
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:12，代码来源:RowStoreAVLMemory.java
示例13: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
Object[] data = row.getData();
switch (changeAction) {
case RowAction.ACTION_DELETE :
database.logger.writeDeleteStatement(session, (Table) table,
data);
if (txModel == TransactionManager.LOCKS) {
remove(row);
}
break;
case RowAction.ACTION_INSERT :
database.logger.writeInsertStatement(session, row,
(Table) table);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
if (txModel == TransactionManager.LOCKS) {
remove(row);
}
break;
case RowAction.ACTION_DELETE_FINAL :
throw Error.runtimeError(ErrorCode.U_S0500, "RowStore");
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:34，代码来源:RowStoreAVLDisk.java
示例14: add
import org.hsqldb.RowAction; //导入依赖的package包/类
public synchronized void add(Session session, CachedObject object,
boolean tx) {
super.add(session, object, tx);
if (tx) {
RowAction.addInsertAction(session, (Table) table, (Row) object);
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:10，代码来源:RowStoreAVLHybridExtended.java
示例15: canRead
import org.hsqldb.RowAction; //导入依赖的package包/类
public boolean canRead(Session session, CachedObject object, int mode,
int[] colMap) {
RowAction action = ((Row) object).rowAction;
if (action == null) {
return true;
}
return action.canRead(session, mode);
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:12，代码来源:RowStoreAVL.java
示例16: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
cache.removePersistence(row);
break;
case RowAction.ACTION_INSERT :
commitPersistence(row);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
if (txModel == TransactionManager.LOCKS) {
remove(row);
} else {
delete(session, row);
remove(row);
}
break;
case RowAction.ACTION_DELETE_FINAL :
throw Error.runtimeError(ErrorCode.U_S0500, "RowStore");
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:29，代码来源:RowStoreAVLDiskData.java
示例17: rollbackRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void rollbackRow(Session session, Row row, int changeAction,
int txModel) {
switch (changeAction) {
case RowAction.ACTION_DELETE :
if (txModel == TransactionManager.LOCKS) {
((RowAVL) row).setNewNodes(this);
indexRow(session, row);
}
break;
case RowAction.ACTION_INSERT :
if (txModel == TransactionManager.LOCKS) {
delete(session, row);
remove(row);
}
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
if (txModel == TransactionManager.LOCKS) {
remove(row);
} else {
delete(session, row);
remove(row);
}
break;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:32，代码来源:RowStoreAVLDiskData.java
示例18: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
Object[] data = row.getData();
switch (changeAction) {
case RowAction.ACTION_DELETE :
database.logger.writeDeleteStatement(session, (Table) table,
data);
break;
case RowAction.ACTION_INSERT :
database.logger.writeInsertStatement(session, row,
(Table) table);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
break;
case RowAction.ACTION_DELETE_FINAL :
delete(session, row);
break;
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:28，代码来源:RowStoreAVLMemory.java
示例19: commitRow
import org.hsqldb.RowAction; //导入依赖的package包/类
public void commitRow(Session session, Row row, int changeAction,
int txModel) {
Object[] data = row.getData();
switch (changeAction) {
case RowAction.ACTION_DELETE :
database.logger.writeDeleteStatement(session, (Table) table,
data);
if (txModel == TransactionManager.LOCKS) {
remove(row);
}
break;
case RowAction.ACTION_INSERT :
database.logger.writeInsertStatement(session, row,
(Table) table);
break;
case RowAction.ACTION_INSERT_DELETE :
// INSERT + DELETE
if (txModel == TransactionManager.LOCKS) {
remove(row);
}
break;
case RowAction.ACTION_DELETE_FINAL :
delete(session, row);
// remove info after delete but before removing persistence
database.txManager.removeTransactionInfo(row);
remove(row);
break;
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:39，代码来源:RowStoreAVLDisk.java
示例20: add
import org.hsqldb.RowAction; //导入依赖的package包/类
public void add(Session session, CachedObject object, boolean tx) {
if (isCached) {
int size = object.getRealSize(cache.rowOut);
size += indexList.length * NodeAVLDisk.SIZE_IN_BYTE;
size = cache.rowOut.getStorageSize(size);
object.setStorageSize(size);
long pos = tableSpace.getFilePosition(size, false);
object.setPos(pos);
if (tx) {
RowAction.addInsertAction(session, (Table) table,
(Row) object);
}
cache.add(object);
} else {
if (tx) {
RowAction.addInsertAction(session, (Table) table,
(Row) object);
}
}
Object[] data = ((Row) object).getData();
for (int i = 0; i < nullsList.length; i++) {
if (data[i] == null) {
nullsList[i] = true;
}
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:36，代码来源:RowStoreAVLHybridExtended.java
注：本文中的org.hsqldb.RowAction类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论