本文整理汇总了Java中org.hsqldb.rowio.RowInputInterface类的典型用法代码示例。如果您正苦于以下问题：Java RowInputInterface类的具体用法？Java RowInputInterface怎么用？Java RowInputInterface使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RowInputInterface类属于org.hsqldb.rowio包，在下文中一共展示了RowInputInterface类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: newNode
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
static final Node newNode(Row r, RowInputInterface in, int id,
Table t) throws IOException, HsqlException {
switch (t.getIndexType()) {
case Index.MEMORY_INDEX :
return new MemoryNode(r);
case Index.POINTER_INDEX :
return new PointerNode((CachedRow) r, id);
case Index.DISK_INDEX :
default :
return new DiskNode((CachedRow) r, in, id);
}
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:17，代码来源:Node.java
示例2: writeTransactionRows
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
void writeTransactionRows() {
for (int i = 0, size = transactionRowLookup.size(); i < size; i++) {
if (transactionRowLookup.getValue(i) != 0) {
continue;
}
int key = transactionRowLookup.getKey(i);
try {
transactionRowLookup.setValue(i, (int) (fileOffset / scale));
RowInputInterface rowIn = cache.readObject(key);
fileStreamOut.write(rowIn.getBuffer(), 0, rowIn.getSize());
fileOffset += rowIn.getSize();
} catch (IOException e) {}
}
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:21，代码来源:DataFileDefrag.java
示例3: NodeAVLDisk
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public NodeAVLDisk(RowAVLDisk r, RowInputInterface in,
int id) throws IOException {
row = r;
iId = id;
iBalance = in.readInt();
iLeft = in.readInt();
iRight = in.readInt();
iParent = in.readInt();
if (iLeft <= 0) {
iLeft = NO_POS;
}
if (iRight <= 0) {
iRight = NO_POS;
}
if (iParent <= 0) {
iParent = NO_POS;
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:23，代码来源:NodeAVLDisk.java
示例4: RowDiskDataChange
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache.
*
* @param t table
* @param in data source
* @throws IOException
*/
public RowDiskDataChange(Session session, TableBase t,
RowInputInterface in) throws IOException {
super(t, in);
targetTable = t.database.schemaManager.findTable(session,
(String) rowData[COL_POS_TABLE_NAME],
(String) rowData[COL_POS_SCHEMA_NAME], null);
if ((Boolean) rowData[COL_POS_IS_UPDATE]) {
updateData = in.readData(targetTable.colTypes);
RowInputBinary bin = (RowInputBinary) in;
if (bin.readNull()) {
updateColMap = null;
} else {
updateColMap = bin.readIntArray();
}
} else {
updateData = null;
updateColMap = null;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:32，代码来源:RowDiskDataChange.java
示例5: NodeAVLDisk
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public NodeAVLDisk(RowAVLDisk r, RowInputInterface in,
int id) throws IOException {
super(r);
iId = id;
iBalance = in.readInt();
iLeft = in.readInt();
iRight = in.readInt();
iParent = in.readInt();
if (iLeft <= 0) {
iLeft = NO_POS;
}
if (iRight <= 0) {
iRight = NO_POS;
}
if (iParent <= 0) {
iParent = NO_POS;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:24，代码来源:NodeAVLDisk.java
示例6: RowDiskDataChange
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache.
*
* @param t table
* @param in data source
* @throws IOException
*/
public RowDiskDataChange(Session session, TableBase t,
RowInputInterface in) throws IOException {
super(t, in);
targetTable = t.database.schemaManager.getTable(session,
(String) rowData[COL_POS_TABLE_NAME],
(String) rowData[COL_POS_SCHEMA_NAME]);
if ((Boolean) rowData[COL_POS_IS_UPDATE]) {
updateData = in.readData(targetTable.colTypes);
RowInputBinary bin = (RowInputBinary) in;
if (bin.readNull()) {
updateColMap = null;
} else {
updateColMap = bin.readIntArray();
}
} else {
updateData = null;
updateColMap = null;
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:32，代码来源:RowDiskDataChange.java
示例7: RowAVLDisk
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache.
*
* @param t table
* @param in data source
* @throws IOException
*/
public RowAVLDisk(TableBase t,
RowInputInterface in) throws IOException {
tTable = t;
position = in.getPos();
storageSize = in.getSize();
int indexcount = t.getIndexCount();
nPrimaryNode = new NodeAVLDisk(this, in, 0);
NodeAVL n = nPrimaryNode;
for (int i = 1; i < indexcount; i++) {
n.nNext = new NodeAVLDisk(this, in, i);
n = n.nNext;
}
rowData = in.readData(tTable.getColumnTypes());
}
开发者ID:s-store，项目名称:sstore-soft，代码行数:28，代码来源:RowAVLDisk.java
示例8: NodeAVLDisk
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public NodeAVLDisk(RowAVLDisk r, RowInputInterface in,
int id) throws IOException {
row = r;
iId = id;
iData = r.getPos();
iBalance = in.readInt();
iLeft = in.readInt();
if (iLeft <= 0) {
iLeft = NO_POS;
}
iRight = in.readInt();
if (iRight <= 0) {
iRight = NO_POS;
}
iParent = in.readInt();
if (iParent <= 0) {
iParent = NO_POS;
}
}
开发者ID:s-store，项目名称:sstore-soft，代码行数:26，代码来源:NodeAVLDisk.java
示例9: read
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public void read(RowInputInterface in,
ResultMetaData meta) throws IOException {
id = in.readLong();
size = in.readInt();
currentOffset = in.readInt();
baseBlockSize = in.readInt();
if (table.length < baseBlockSize) {
table = new Object[baseBlockSize][];
}
for (int i = 0; i < baseBlockSize; i++) {
table[i] = in.readData(meta.columnTypes);
}
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:17，代码来源:RowSetNavigatorClient.java
示例10: readRow
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
boolean readRow(RowInputInterface rowin, int pos) throws IOException {
try {
int length = dataStreamIn.readInt();
int count = 4;
if (length == 0) {
return false;
}
rowin.resetRow(pos, length);
dataStreamIn.readFully(rowin.getBuffer(), count, length - count);
return true;
} catch (EOFException e) {
return false;
}
}
开发者ID:s-store，项目名称:s-store，代码行数:19，代码来源:ScriptReaderBinary.java
示例11: CachedRow
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache.
*
* @param t table
* @param in data source
* @throws IOException
* @throws HsqlException
*/
public CachedRow(Table t,
RowInputInterface in) throws IOException, HsqlException {
tTable = t;
iPos = in.getPos();
storageSize = in.getSize();
int indexcount = t.getIndexCount();
nPrimaryNode = Node.newNode(this, in, 0, t);
Node n = nPrimaryNode;
for (int i = 1; i < indexcount; i++) {
n.nNext = Node.newNode(this, in, i, t);
n = n.nNext;
}
oData = in.readData(tTable.getColumnTypes());
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:29，代码来源:CachedRow.java
示例12: read
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public void read(RowInputInterface in) {
this.position = in.getPos();
int[] array = bitMap.getIntArray();
int capacity = array.length;
try {
for (int i = 0; i < capacity; i++) {
array[i] = in.readInt();
}
} catch (IOException e) {
throw Error.error(ErrorCode.GENERAL_IO_ERROR, e);
}
hasChanged = false;
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:18，代码来源:BitMapCachedObject.java
示例13: CachedRow
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache.
*
* @param t table
* @param in data source
* @throws IOException
* @throws HsqlException
*/
public CachedRow(Table t,
RowInputInterface in) throws IOException, HsqlException {
tTable = t;
iPos = in.getPos();
storageSize = in.getSize();
int indexcount = t.getIndexCount();
nPrimaryNode = Node.newNode(this, in, 0, t);
Node n = nPrimaryNode;
for (int i = 1; i < indexcount; i++) {
n.nNext = Node.newNode(this, in, i, t);
n = n.nNext;
}
oData = in.readData(tTable.getColumnTypes(), tTable.columnCount);
setPos(iPos);
// change from 1.7.0 format - the check is no longer read or written
// Trace.check(in.readIntData() == iPos, Trace.INPUTSTREAM_ERROR);
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:34，代码来源:CachedRow.java
示例14: get
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public CachedObject get(RowInputInterface in) {
try {
if (isCached) {
return new RowAVLDisk(table, in);
}
} catch (HsqlException e) {
return null;
} catch (IOException e1) {
return null;
}
return null;
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:15，代码来源:RowStoreAVLHybrid.java
示例15: get
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public CachedObject get(RowInputInterface in) {
try {
return new RowDiskDataChange(session, table, in);
} catch (HsqlException e) {
return null;
} catch (IOException e1) {
return null;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:11，代码来源:RowStoreDataChange.java
示例16: TextFileReader8
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
TextFileReader8(RandomAccessInterface dataFile,
TextFileSettings textFileSettings,
RowInputInterface rowIn, boolean isReadOnly) {
this.dataFile = dataFile;
this.textFileSettings = textFileSettings;
this.rowIn = rowIn;
this.isReadOnly = isReadOnly;
this.buffer = StringCreator.getStringCreator(byte.class,
textFileSettings.charEncoding);
skipBOM();
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:14，代码来源:TextFileReader8.java
示例17: newTextFileReader
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
static TextFileReader newTextFileReader(RandomAccessInterface dataFile,
TextFileSettings textFileSettings, RowInputInterface rowIn,
boolean isReadOnly) {
if (textFileSettings.isUTF16) {
return new TextFileReader16(dataFile, textFileSettings, rowIn,
isReadOnly);
} else {
return new TextFileReader8(dataFile, textFileSettings, rowIn,
isReadOnly);
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:13，代码来源:TextFileReader8.java
示例18: get
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
public CachedObject get(RowInputInterface in) {
try {
if (largeData) {
return new RowAVLDiskLarge(table, in);
} else {
return new RowAVLDisk(table, in);
}
} catch (IOException e) {
throw Error.error(ErrorCode.DATA_FILE_ERROR, e);
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:13，代码来源:RowStoreAVLDisk.java
示例19: CachedDataRow
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache. The link with
* the Nodes is made separetly.
*/
CachedDataRow(Table t,
RowInputInterface in) throws IOException, HsqlException {
tTable = t;
iPos = in.getPos();
storageSize = in.getSize();
oData = in.readData(tTable.getColumnTypes(), tTable.columnCount);
setPos(iPos);
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:15，代码来源:CachedDataRow.java
示例20: CachedDataRow
import org.hsqldb.rowio.RowInputInterface; //导入依赖的package包/类
/**
* Constructor when read from the disk into the Cache. The link with
* the Nodes is made separetly.
*/
CachedDataRow(Table t,
RowInputInterface in) throws IOException, HsqlException {
tTable = t;
iPos = in.getPos();
storageSize = in.getSize();
oData = in.readData(tTable.getColumnTypes());
hasDataChanged = false;
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:14，代码来源:CachedDataRow.java
注：本文中的org.hsqldb.rowio.RowInputInterface类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论