本文整理汇总了Java中org.hsqldb.rowio.RowOutputBinary类的典型用法代码示例。如果您正苦于以下问题：Java RowOutputBinary类的具体用法？Java RowOutputBinary怎么用？Java RowOutputBinary使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RowOutputBinary类属于org.hsqldb.rowio包，在下文中一共展示了RowOutputBinary类的15个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getRealSize
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public int getRealSize(RowOutputInterface out) {
RowOutputBinary bout = (RowOutputBinary) out;
int size = out.getSize(this);
if (updateData != null) {
size += bout.getSize(updateData, targetTable.getColumnCount(),
targetTable.getColumnTypes());
if (updateColMap != null) {
size += bout.getSize(updateColMap);
}
}
return size;
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:17，代码来源:RowDiskDataChange.java
示例2: ServerConnection
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* Creates a new ServerConnection to the specified Server on the
* specified socket.
*
* @param socket the network socket on which Server communication
* takes place
* @param server the Server instance to which the object
* represents a connection
*/
ServerConnection(Socket socket, Server server) {
RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);
rowIn = new RowInputBinary(rowOutTemp);
rowOut = rowOutTemp;
//
Thread runnerThread;
this.socket = socket;
this.server = server;
mThread = mCurrentThread.getAndIncrement();
synchronized (server.serverConnSet) {
server.serverConnSet.add(this);
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:28，代码来源:ServerConnection.java
示例3: writeMulti
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
private void writeMulti(RowOutputBinary out)
throws IOException, HsqlException {
int startPos = out.size();
out.writeSize(0);
out.writeIntData(mode);
out.writeIntData(databaseID);
out.writeIntData(sessionID);
out.writeIntData(size);
Record n = rRoot;
while (n != null) {
((Result) n.data[0]).write(out);
n = n.next;
}
out.writeIntData(out.size(), startPos);
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:22，代码来源:Result.java
示例4: initStructures
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* resultOut is reused to trasmit all remote calls for session management.
* Here the structure is preset for sending attributes.
*/
private void initStructures() {
rowOut = new RowOutputBinary(mainBuffer);
rowIn = new RowInputBinary(rowOut);
resultOut = new Result(ResultConstants.DATA, 7);
resultOut.metaData.colNames = resultOut.metaData.colLabels =
resultOut.metaData.tableNames = new String[] {
"", "", "", "", "", "", ""
};
resultOut.add(new Object[7]);
resultOut.metaData.colTypes = new int[] {
Types.VARCHAR, Types.VARCHAR, Types.INTEGER, Types.INTEGER,
Types.BOOLEAN, Types.BOOLEAN, Types.BOOLEAN
};
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:22，代码来源:HSQLClientConnection.java
示例5: ServerConnection
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* Creates a new ServerConnection to the specified Server on the
* specified socket.
*
* @param socket the network socket on which Server communication
* takes place
* @param server the Server instance to which the object
* represents a connection
*/
ServerConnection(Socket socket, Server server) {
RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);
rowIn = new RowInputBinary(rowOutTemp);
rowOut = rowOutTemp;
//
Thread runnerThread;
this.socket = socket;
this.server = server;
synchronized (ServerConnection.class) {
mThread = mCurrentThread++;
}
synchronized (server.serverConnSet) {
server.serverConnSet.add(this);
}
}
开发者ID:RabadanLab，项目名称:Pegasus，代码行数:31，代码来源:ServerConnection.java
示例6: write
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public void write(RowOutputInterface out) {
writeNodes(out);
if (hasDataChanged) {
out.writeData(this, table.colTypes);
if (updateData != null) {
Type[] targetTypes = targetTable.colTypes;
out.writeData(targetTypes.length, targetTypes, updateData,
null, null);
RowOutputBinary bout = (RowOutputBinary) out;
if (updateColMap == null) {
bout.writeNull(Type.SQL_ARRAY_ALL_TYPES);
} else {
bout.writeArray(updateColMap);
}
}
out.writeEnd();
hasDataChanged = false;
}
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:28，代码来源:RowDiskDataChange.java
示例7: initStructures
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* resultOut is reused to transmit all remote calls for session management.
* Here the structure is preset for sending attributes.
*/
private void initStructures() {
RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);
rowOut = rowOutTemp;
rowIn = new RowInputBinary(rowOutTemp);
resultOut = Result.newSessionAttributesResult();
}
开发者ID:tiweGH，项目名称:OpenDiabetes，代码行数:13，代码来源:ClientConnection.java
示例8: initStructures
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* resultOut is reused to trasmit all remote calls for session management.
* Here the structure is preset for sending attributes.
*/
private void initStructures() {
RowOutputBinary rowOutTemp = new RowOutputBinary(mainBuffer);
rowOut = rowOutTemp;
rowIn = new RowInputBinary(rowOutTemp);
resultOut = Result.newSessionAttributesResult();
}
开发者ID:Julien35，项目名称:dev-courses，代码行数:13，代码来源:ClientConnection.java
示例9: initBuffers
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
protected void initBuffers() throws HsqlException {
rowOut = RowOutputBase.newRowOutput(cachedRowType);
rowIn = RowInputBase.newRowInput(cachedRowType);
rowStoreExtra = rowOut instanceof RowOutputBinary
? ROW_STORE_EXTRA_170
: ROW_STORE_EXTRA_160;
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:9，代码来源:Cache.java
示例10: write
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
void write(RowOutputBinary out,
int colCount) throws HsqlException, IOException {
out.writeIntData(colCount);
for (int i = 0; i < colCount; i++) {
out.writeType(colTypes[i]);
// CAREFUL: writeString will throw NPE if passed NULL
// There is no guarantee that these will all be non-null
// and there's no point in hanging network communications
// or doing a big rewrite for null-safety over something
// like this. We could explicitly do a writeNull here if
// detected null, but, frankly, readString on the other
// end will simply turn it into a zero-length string
// anyway, as nulls are only handled "properly" by
// readData(...), not by the individual readXXX methods.
out.writeString(colLabels[i] == null ? ""
: colLabels[i]);
out.writeString(tableNames[i] == null ? ""
: tableNames[i]);
out.writeString(colNames[i] == null ? ""
: colNames[i]);
out.writeString(classNames[i] == null ? ""
: classNames[i]);
if (isTableColumn(i)) {
writeTableColumnAttrs(out, i);
}
if (isParameterDescription) {
out.writeIntData(paramMode[i]);
}
}
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:36，代码来源:Result.java
示例11: write
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
void write(RowOutputBinary out,
int colCount) throws HsqlException, IOException {
out.writeIntData(colCount);
for (int i = 0; i < colCount; i++) {
out.writeType(colTypes[i]);
// fredt - 1.8.0 added
out.writeIntData(colSizes[i]);
out.writeIntData(colScales[i]);
out.writeString(colLabels[i] == null ? ""
: colLabels[i]);
out.writeString(tableNames[i] == null ? ""
: tableNames[i]);
out.writeString(colNames[i] == null ? ""
: colNames[i]);
out.writeString(classNames[i] == null ? ""
: classNames[i]);
if (isTableColumn(i)) {
writeTableColumnAttrs(out, i);
}
if (isParameterDescription) {
out.writeIntData(paramMode[i]);
}
}
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:30，代码来源:Result.java
示例12: initStructures
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* resultOut is reused to trasmit all remote calls for session management.
* Here the structure is preset for sending attributes.
*/
private void initStructures() {
rowOut = new RowOutputBinary(mainBuffer);
rowIn = new RowInputBinary(rowOut);
resultOut = Result.newSessionAttributesResult();
resultOut.add(new Object[7]);
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:13，代码来源:HSQLClientConnection.java
示例13: write
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
public void write(RowOutputInterface out) {
try {
writeNodes(out);
if (hasDataChanged) {
out.writeData(this, table.colTypes);
if (updateData != null) {
Type[] targetTypes = targetTable.colTypes;
out.writeData(targetTypes.length, targetTypes, updateData,
null, null);
RowOutputBinary bout = (RowOutputBinary) out;
if (updateColMap == null) {
bout.writeNull(Type.SQL_ARRAY_ALL_TYPES);
} else {
bout.writeArray(updateColMap);
}
}
out.writeEnd();
hasDataChanged = false;
}
} catch (IOException e) {}
}
开发者ID:RabadanLab，项目名称:Pegasus，代码行数:30，代码来源:RowDiskDataChange.java
示例14: initBuffers
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
protected void initBuffers() {
rowOut = new RowOutputBinary();
}
开发者ID:s-store，项目名称:sstore-soft，代码行数:4，代码来源:ScriptWriterBinary.java
示例15: init
import org.hsqldb.rowio.RowOutputBinary; //导入依赖的package包/类
/**
* Method declaration
*
*
* @param config
*/
public void init(ServletConfig config) {
try {
super.init(config);
rowOut = new RowOutputBinary(BUFFER_SIZE);
rowIn = new RowInputBinary(rowOut);
} catch (ServletException exp) {
log(exp.getMessage());
}
String dbStr = getInitParameter("hsqldb.server.database");
if (dbStr == null) {
dbStr = ".";
}
// begin WEB-INF patch */
String useWebInfStr =
getInitParameter("hsqldb.server.use_web-inf_path");
if (!dbStr.equals(".") && "true".equalsIgnoreCase(useWebInfStr)) {
dbStr = getServletContext().getRealPath("/") + "WEB-INF" + dbStr;
}
// end WEB-INF patch
HsqlProperties dbURL = DatabaseManager.parseURL(dbStr, false);
log("Database filename = " + dbStr);
if (dbURL == null) {
errorStr = "Bad Database name";
} else {
dbPath = dbURL.getProperty("database");
dbType = dbURL.getProperty("connection_type");
try {
// [email protected] 1.7.2 patch properties on the JDBC URL
DatabaseManager.getDatabase(dbType, dbPath, false, dbURL);
} catch (HsqlException e) {
errorStr = e.getMessage();
}
}
log(errorStr);
log("Initialization completed.");
}
开发者ID:parabuild-ci，项目名称:parabuild-ci，代码行数:55，代码来源:Servlet.java
注：本文中的org.hsqldb.rowio.RowOutputBinary类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论