Java 类java.sql.SQLOutput 实例源码

项目：jdk8u-jdk 文件：TestSQLDataImpl.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {

    stream.writeString((String) types[stringPos]);
    stream.writeDate((Date) types[datePos]);
    stream.writeTime((Time) types[timePos]);
    stream.writeTimestamp((Timestamp) types[timestampPos]);
    stream.writeInt((Integer) types[intPos]);
    stream.writeLong((Long) types[longPos]);
    stream.writeShort((Short) types[shortPos]);
    stream.writeBigDecimal((BigDecimal) types[bigDecimalPos]);
    stream.writeDouble((Double) types[doublePos]);
    stream.writeBoolean((Boolean) types[booleanPos]);
    stream.writeFloat((Float) types[floatPos]);
    stream.writeByte((Byte) types[bytePos]);
    stream.writeBytes((byte[]) types[bytesPos]);
}

项目：openjdk-jdk10 文件：TestSQLDataImpl.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {

    stream.writeString((String) types[stringPos]);
    stream.writeDate((Date) types[datePos]);
    stream.writeTime((Time) types[timePos]);
    stream.writeTimestamp((Timestamp) types[timestampPos]);
    stream.writeInt((Integer) types[intPos]);
    stream.writeLong((Long) types[longPos]);
    stream.writeShort((Short) types[shortPos]);
    stream.writeBigDecimal((BigDecimal) types[bigDecimalPos]);
    stream.writeDouble((Double) types[doublePos]);
    stream.writeBoolean((Boolean) types[booleanPos]);
    stream.writeFloat((Float) types[floatPos]);
    stream.writeByte((Byte) types[bytePos]);
    stream.writeBytes((byte[]) types[bytesPos]);
}

项目：openjdk9 文件：TestSQLDataImpl.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {

    stream.writeString((String) types[stringPos]);
    stream.writeDate((Date) types[datePos]);
    stream.writeTime((Time) types[timePos]);
    stream.writeTimestamp((Timestamp) types[timestampPos]);
    stream.writeInt((Integer) types[intPos]);
    stream.writeLong((Long) types[longPos]);
    stream.writeShort((Short) types[shortPos]);
    stream.writeBigDecimal((BigDecimal) types[bigDecimalPos]);
    stream.writeDouble((Double) types[doublePos]);
    stream.writeBoolean((Boolean) types[booleanPos]);
    stream.writeFloat((Float) types[floatPos]);
    stream.writeByte((Byte) types[bytePos]);
    stream.writeBytes((byte[]) types[bytesPos]);
}

项目：jdk8u_jdk 文件：TestSQLDataImpl.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {

    stream.writeString((String) types[stringPos]);
    stream.writeDate((Date) types[datePos]);
    stream.writeTime((Time) types[timePos]);
    stream.writeTimestamp((Timestamp) types[timestampPos]);
    stream.writeInt((Integer) types[intPos]);
    stream.writeLong((Long) types[longPos]);
    stream.writeShort((Short) types[shortPos]);
    stream.writeBigDecimal((BigDecimal) types[bigDecimalPos]);
    stream.writeDouble((Double) types[doublePos]);
    stream.writeBoolean((Boolean) types[booleanPos]);
    stream.writeFloat((Float) types[floatPos]);
    stream.writeByte((Byte) types[bytePos]);
    stream.writeBytes((byte[]) types[bytesPos]);
}

项目：lookaside_java-1.8.0-openjdk 文件：TestSQLDataImpl.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {

    stream.writeString((String) types[stringPos]);
    stream.writeDate((Date) types[datePos]);
    stream.writeTime((Time) types[timePos]);
    stream.writeTimestamp((Timestamp) types[timestampPos]);
    stream.writeInt((Integer) types[intPos]);
    stream.writeLong((Long) types[longPos]);
    stream.writeShort((Short) types[shortPos]);
    stream.writeBigDecimal((BigDecimal) types[bigDecimalPos]);
    stream.writeDouble((Double) types[doublePos]);
    stream.writeBoolean((Boolean) types[booleanPos]);
    stream.writeFloat((Float) types[floatPos]);
    stream.writeByte((Byte) types[bytePos]);
    stream.writeBytes((byte[]) types[bytesPos]);
}

项目：pljava 文件：UDTScalarIOTest.java

@Function(effects=IMMUTABLE, onNullInput=RETURNS_NULL)
@Override
public void writeSQL(SQLOutput stream) throws SQLException
{
    stream.writeBigDecimal(s_bigdec);
    stream.writeBinaryStream(new ByteArrayInputStream(s_utfgedicht));
    stream.writeBoolean(s_bool);
    stream.writeByte(s_byte);
    stream.writeBytes(s_utfgedicht);
    stream.writeCharacterStream(new StringReader(s_gedicht));
    stream.writeDate(s_date);
    stream.writeDouble(s_double);
    stream.writeFloat(s_float);
    stream.writeInt(s_int);
    stream.writeLong(s_long);
    stream.writeShort(s_short);
    stream.writeString(s_gedicht);
    stream.writeTime(s_time);
    stream.writeTimestamp(s_timestamp);
    stream.writeURL(s_url);
}

项目：jdk8u-jdk 文件：SuperHero.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
    stream.writeInt(firstYear);
    stream.writeString(secretIdentity);
}

项目：openjdk-jdk10 文件：SuperHero.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
    stream.writeInt(firstYear);
    stream.writeString(secretIdentity);
}

项目：openjdk9 文件：SuperHero.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
    stream.writeInt(firstYear);
    stream.writeString(secretIdentity);
}

项目：jdk8u_jdk 文件：SuperHero.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
    stream.writeInt(firstYear);
    stream.writeString(secretIdentity);
}

项目：lookaside_java-1.8.0-openjdk 文件：SuperHero.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
    stream.writeInt(firstYear);
    stream.writeString(secretIdentity);
}

项目：pljava 文件：ComplexScalar.java

@Function(effects=IMMUTABLE, onNullInput=RETURNS_NULL)
@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    s_logger.info(m_typeName + " to SQLOutput");
    stream.writeDouble(m_x);
    stream.writeDouble(m_y);
}

项目：In-the-Box-Fork 文件：SQLDataTest.java

/**
 * Test method for {@link java.sql.SQLData#writeSQL(java.sql.SQLOutput)}.
 */
@TestTargetNew(
  level = TestLevel.NOT_FEASIBLE,
  notes = "",
      method = "writeSQL",
      args = {SQLOutput.class}
    )
public void testWriteSQL() {
    fail("Not yet implemented");
}

项目：mongodb-rdbms-sync 文件：O2MSyncEventLog.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(this.tableName);
    stream.writeString(this.columnName);
    stream.writeString(String.valueOf(this.columnValue));
}

项目：gemfirexd-oss 文件：SampleSQLData.java

public void writeSQL( SQLOutput out ) throws SQLException
{
    out.writeBytes( _data );
}

项目：pljava 文件：VarlenaUDTTest.java

public void writeSQL( SQLOutput stream) throws SQLException {
    for ( int i = 0 ; i < apop ; ++ i )
        stream.writeByte( (byte)'a');
}

项目：pljava 文件：ComplexTuple.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeDouble(m_x);
    stream.writeDouble(m_y);
    s_logger.info(m_typeName + " to SQLOutput");
}

项目：pljava 文件：IntWithMod.java

@Function(effects=IMMUTABLE, onNullInput=RETURNS_NULL)
@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeInt(m_value);
}

项目：pljava 文件：Point.java

@Override
public void writeSQL(SQLOutput stream) throws SQLException {
    s_logger.info(m_typeName + " to SQLOutput");
    stream.writeDouble(m_x);
    stream.writeDouble(m_y);
}

项目：pljava 文件：DDRProcessor.java

DDRProcessorImpl( ProcessingEnvironment processingEnv)
{
    elmu = processingEnv.getElementUtils();
    filr = processingEnv.getFiler();
    loca = processingEnv.getLocale();
    msgr = processingEnv.getMessager();
    opts = processingEnv.getOptions();
    srcv = processingEnv.getSourceVersion();
    typu = processingEnv.getTypeUtils();

    tmpr = new TypeMapper();

    String optv;

    optv = opts.get( "ddr.name.trusted");
    if ( null != optv )
        nameTrusted = optv;
    else
        nameTrusted = "java";

    optv = opts.get( "ddr.name.untrusted");
    if ( null != optv )
        nameUntrusted = optv;
    else
        nameUntrusted = "javaU";

    optv = opts.get( "ddr.implementor");
    if ( null != optv )
        defaultImplementor = "-".equals( optv) ? null : optv;
    else
        defaultImplementor = "PostgreSQL";

    optv = opts.get( "ddr.output");
    if ( null != optv )
        output = optv;
    else
        output = "pljava.ddr";

    TY_ITERATOR = typu.getDeclaredType(
        elmu.getTypeElement( java.util.Iterator.class.getName()));
    TY_OBJECT = typu.getDeclaredType(
        elmu.getTypeElement( Object.class.getName()));
    TY_RESULTSET = typu.getDeclaredType(
        elmu.getTypeElement( java.sql.ResultSet.class.getName()));
    TY_RESULTSETPROVIDER = typu.getDeclaredType(
        elmu.getTypeElement( ResultSetProvider.class.getName()));
    TY_RESULTSETHANDLE = typu.getDeclaredType(
        elmu.getTypeElement( ResultSetHandle.class.getName()));
    TY_SQLDATA = typu.getDeclaredType(
        elmu.getTypeElement( SQLData.class.getName()));
    TY_SQLINPUT = typu.getDeclaredType(
        elmu.getTypeElement( SQLInput.class.getName()));
    TY_SQLOUTPUT = typu.getDeclaredType(
        elmu.getTypeElement( SQLOutput.class.getName()));
    TY_STRING = typu.getDeclaredType(
        elmu.getTypeElement( String.class.getName()));
    TY_TRIGGERDATA = typu.getDeclaredType(
        elmu.getTypeElement( TriggerData.class.getName()));
    TY_VOID = typu.getNoType( TypeKind.VOID);

    AN_FUNCTION    = elmu.getTypeElement( Function.class.getName());
    AN_SQLACTION   = elmu.getTypeElement( SQLAction.class.getName());
    AN_SQLACTIONS  = elmu.getTypeElement( SQLActions.class.getName());
    AN_SQLTYPE     = elmu.getTypeElement( SQLType.class.getName());
    AN_TRIGGER     = elmu.getTypeElement( Trigger.class.getName());
    AN_BASEUDT     = elmu.getTypeElement( BaseUDT.class.getName());
    AN_MAPPEDUDT   = elmu.getTypeElement( MappedUDT.class.getName());
}

项目：gemfirexd-oss 文件：SampleSQLData.java

public void writeSQL( SQLOutput out ) throws SQLException
{
    out.writeBytes( _data );
}

项目：pljava-udt-type-extension 文件：RationalUDT.java

/**
 * Write object to SQLOutput stream.
 */
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeLong(value.getNumerator());
    stream.writeLong(value.getDenominator());
}

项目：pljava-udt-type-extension 文件：ComplexUDT.java

/**
 * Write object to SQLOutput stream.
 */
public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeDouble(value.Re());
    stream.writeDouble(value.Im());
}

项目：cn1 文件：SQLInputImplTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(firstAttribute);
    stream.writeBoolean(secondAttribute);
    stream.writeString(thirdAttribute);
    stream.writeInt(fourthAttribute);
}

项目：cn1 文件：SerialStructTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
}

项目：cn1 文件：SerialStructTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeInt(id);
    stream.writeObject(name);
}

项目：cn1 文件：SerialArrayTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    return;
}

项目：cn1 文件：SerialArrayTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    return;
}

项目：freeVM 文件：SQLInputImplTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(firstAttribute);
    stream.writeBoolean(secondAttribute);
    stream.writeString(thirdAttribute);
    stream.writeInt(fourthAttribute);
}

项目：freeVM 文件：SerialStructTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeString(first);
    stream.writeString(last);
}

项目：freeVM 文件：SerialStructTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeInt(id);
    stream.writeObject(name);
}

项目：freeVM 文件：SerialArrayTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    return;
}

项目：freeVM 文件：SerialArrayTest.java

public void writeSQL(SQLOutput stream) throws SQLException {
    return;
}

项目：spliceengine 文件：SampleSQLData.java

public void writeSQL( SQLOutput out ) throws SQLException
{
    out.writeBytes( _data );
}

项目：couchbase-to-oracle 文件：CouchbaseViewer.java

public void writeSQL(SQLOutput stream) throws SQLException {
    stream.writeBigDecimal(key);

}