|
HSQLDB example source code file (RowInputBase.java)
The HSQLDB RowInputBase.java source code/* Copyright (c) 2001-2008, The HSQL Development Group * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, this * list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * * Neither the name of the HSQL Development Group nor the names of its * contributors may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL HSQL DEVELOPMENT GROUP, HSQLDB.ORG, * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ package org.hsqldb.rowio; import java.io.IOException; import java.math.BigDecimal; import java.sql.Date; import java.sql.Time; import java.sql.Timestamp; import org.hsqldb.HsqlException; import org.hsqldb.Trace; import org.hsqldb.Types; import org.hsqldb.lib.HsqlByteArrayInputStream; import org.hsqldb.types.Binary; /** * Base class for reading the data for a database row in different formats. * Defines the methods that are independent of storage format and declares * the format-dependent methods that subclasses should define. * * @author sqlbob@users (RMP) * @author fredt@users * @version 1.7.2 * @since 1.7.0 */ public abstract class RowInputBase extends HsqlByteArrayInputStream { static final int NO_POS = -1; // fredt - initialisation may be unnecessary as it's done in resetRow() protected int filePos = NO_POS; protected int size; public RowInputBase() { this(new byte[4]); } /** * Constructor takes a complete row */ public RowInputBase(byte[] buf) { super(buf); size = buf.length; } public int getPos() { if (filePos == NO_POS) { // Trace.printSystemOut(Trace.DatabaseRowInput_getPos); } return (filePos); } public int getSize() { return size; } // fredt@users - comment - methods used for node and type data public abstract int readIntData() throws IOException; public abstract long readLongData() throws IOException; public abstract int readType() throws IOException; public abstract String readString() throws IOException; // fredt@users - comment - methods used for SQL types protected abstract boolean checkNull() throws IOException; protected abstract String readChar(int type) throws IOException, HsqlException; protected abstract Integer readSmallint() throws IOException, HsqlException; protected abstract Integer readInteger() throws IOException, HsqlException; protected abstract Long readBigint() throws IOException, HsqlException; protected abstract Double readReal(int type) throws IOException, HsqlException; protected abstract BigDecimal readDecimal() throws IOException, HsqlException; protected abstract Boolean readBit() throws IOException, HsqlException; protected abstract Time readTime() throws IOException, HsqlException; protected abstract Date readDate() throws IOException, HsqlException; protected abstract Timestamp readTimestamp() throws IOException, HsqlException; protected abstract Object readOther() throws IOException, HsqlException; protected abstract Binary readBinary(int type) throws IOException, HsqlException; /** * reads row data from a stream using the JDBC types in colTypes * * @param colTypes * @return * @throws IOException * @throws HsqlException */ public Object[] readData(int[] colTypes) throws IOException, HsqlException { int l = colTypes.length; Object[] data = new Object[l]; Object o; int type; for (int i = 0; i < l; i++) { if (checkNull()) { continue; } o = null; type = colTypes[i]; switch (type) { case Types.NULL : case Types.CHAR : case Types.VARCHAR : case Types.VARCHAR_IGNORECASE : case Types.LONGVARCHAR : o = readChar(type); break; case Types.TINYINT : case Types.SMALLINT : o = readSmallint(); break; case Types.INTEGER : o = readInteger(); break; case Types.BIGINT : o = readBigint(); break; //fredt although REAL is now Double, it is read / written in //the old format for compatibility case Types.REAL : case Types.FLOAT : case Types.DOUBLE : o = readReal(type); break; case Types.NUMERIC : case Types.DECIMAL : o = readDecimal(); break; case Types.DATE : o = readDate(); break; case Types.TIME : o = readTime(); break; case Types.TIMESTAMP : o = readTimestamp(); break; case Types.BOOLEAN : o = readBit(); break; case Types.OTHER : o = readOther(); break; case Types.BINARY : case Types.VARBINARY : case Types.LONGVARBINARY : o = readBinary(type); break; default : throw Trace.runtimeError( Trace.UNSUPPORTED_INTERNAL_OPERATION, "RowInputBase " + Types.getTypeString(type)); } data[i] = o; } return data; } /** * Used to reset the row, ready for a new row to be written into the * byte[] buffer by an external routine. * */ public void resetRow(int filepos, int rowsize) throws IOException { mark = 0; reset(); if (buffer.length < rowsize) { buffer = new byte[rowsize]; } this.filePos = filepos; size = count = rowsize; pos = 4; buffer[0] = (byte) ((rowsize >>> 24) & 0xFF); buffer[1] = (byte) ((rowsize >>> 16) & 0xFF); buffer[2] = (byte) ((rowsize >>> 8) & 0xFF); buffer[3] = (byte) ((rowsize >>> 0) & 0xFF); } public byte[] getBuffer() { return buffer; } public int skipBytes(int n) throws IOException { throw Trace.runtimeError(Trace.UNSUPPORTED_INTERNAL_OPERATION, "RowInputBase"); } public String readLine() throws IOException { throw Trace.runtimeError(Trace.UNSUPPORTED_INTERNAL_OPERATION, "RowInputBase"); } } Other HSQLDB examples (source code examples)Here is a short list of links related to this HSQLDB RowInputBase.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.