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());
}

项目：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;
}

项目：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;
}

项目：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);

}