微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

java.sql.SQLInput的实例源码

项目:jdk8u-jdk    文件TestsqlDataimpl.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {

    sqlType = typeName;
    types[stringPos] = stream.readString();
    types[datePos] = stream.readDate();
    types[timePos] = stream.readTime();
    types[timestampPos] = stream.readTimestamp();
    types[intPos] = stream.readInt();
    types[longPos] = stream.readLong();
    types[shortPos] = stream.readShort();
    types[bigDecimalPos] = stream.readBigDecimal();
    types[doublePos] = stream.readDouble();
    types[booleanPos] = stream.readBoolean();
    types[floatPos] = stream.readFloat();
    types[bytePos] = stream.readByte();
    types[bytesPos] = stream.readBytes();
}
项目:openjdk-jdk10    文件TestsqlDataimpl.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {

    sqlType = typeName;
    types[stringPos] = stream.readString();
    types[datePos] = stream.readDate();
    types[timePos] = stream.readTime();
    types[timestampPos] = stream.readTimestamp();
    types[intPos] = stream.readInt();
    types[longPos] = stream.readLong();
    types[shortPos] = stream.readShort();
    types[bigDecimalPos] = stream.readBigDecimal();
    types[doublePos] = stream.readDouble();
    types[booleanPos] = stream.readBoolean();
    types[floatPos] = stream.readFloat();
    types[bytePos] = stream.readByte();
    types[bytesPos] = stream.readBytes();
}
项目:openjdk9    文件TestsqlDataimpl.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {

    sqlType = typeName;
    types[stringPos] = stream.readString();
    types[datePos] = stream.readDate();
    types[timePos] = stream.readTime();
    types[timestampPos] = stream.readTimestamp();
    types[intPos] = stream.readInt();
    types[longPos] = stream.readLong();
    types[shortPos] = stream.readShort();
    types[bigDecimalPos] = stream.readBigDecimal();
    types[doublePos] = stream.readDouble();
    types[booleanPos] = stream.readBoolean();
    types[floatPos] = stream.readFloat();
    types[bytePos] = stream.readByte();
    types[bytesPos] = stream.readBytes();
}
项目:jdk8u_jdk    文件TestsqlDataimpl.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {

    sqlType = typeName;
    types[stringPos] = stream.readString();
    types[datePos] = stream.readDate();
    types[timePos] = stream.readTime();
    types[timestampPos] = stream.readTimestamp();
    types[intPos] = stream.readInt();
    types[longPos] = stream.readLong();
    types[shortPos] = stream.readShort();
    types[bigDecimalPos] = stream.readBigDecimal();
    types[doublePos] = stream.readDouble();
    types[booleanPos] = stream.readBoolean();
    types[floatPos] = stream.readFloat();
    types[bytePos] = stream.readByte();
    types[bytesPos] = stream.readBytes();
}
项目:lookaside_java-1.8.0-openjdk    文件TestsqlDataimpl.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {

    sqlType = typeName;
    types[stringPos] = stream.readString();
    types[datePos] = stream.readDate();
    types[timePos] = stream.readTime();
    types[timestampPos] = stream.readTimestamp();
    types[intPos] = stream.readInt();
    types[longPos] = stream.readLong();
    types[shortPos] = stream.readShort();
    types[bigDecimalPos] = stream.readBigDecimal();
    types[doublePos] = stream.readDouble();
    types[booleanPos] = stream.readBoolean();
    types[floatPos] = stream.readFloat();
    types[bytePos] = stream.readByte();
    types[bytesPos] = stream.readBytes();
}
项目:jdk8u-jdk    文件SuperHero.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    first = stream.readString();
    last = stream.readString();
    firstYear = stream.readInt();
    secretIdentity = stream.readString();
}
项目:mongodb-rdbms-sync    文件O2MSyncEventLog.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    this.typeName= typeName;
    this.tableName=stream.readString();
    this.columnName= stream.readString();
    this.columnValue=stream.readobject();
}
项目:openjdk-jdk10    文件SuperHero.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    first = stream.readString();
    last = stream.readString();
    firstYear = stream.readInt();
    secretIdentity = stream.readString();
}
项目:openjdk9    文件SuperHero.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    first = stream.readString();
    last = stream.readString();
    firstYear = stream.readInt();
    secretIdentity = stream.readString();
}
项目:jdk8u_jdk    文件SuperHero.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    first = stream.readString();
    last = stream.readString();
    firstYear = stream.readInt();
    secretIdentity = stream.readString();
}
项目:lookaside_java-1.8.0-openjdk    文件SuperHero.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    first = stream.readString();
    last = stream.readString();
    firstYear = stream.readInt();
    secretIdentity = stream.readString();
}
项目:pljava    文件VarlenaUDTTest.java   
public void readsql( sqlInput stream,String typname) throws sqlException {
    this.typname = typname;
    int i = 0;
    for ( ;; ++i )
        try {
            stream.readByte();
        }
        catch ( sqlException sqle ) {
            if ( "22P03".equals( sqle.getsqlState()) )
                break;
            throw sqle;
        }
    apop = i;
}
项目:pljava    文件ComplexTuple.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    m_typeName = typeName;
    m_x = stream.readDouble();
    m_y = stream.readDouble();
    s_logger.info(typeName + " from sqlInput");
}
项目:pljava    文件ComplexScalar.java   
@Function(effects=IMMUTABLE,onNullInput=RETURNS_NULL)
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    s_logger.info(typeName + " from sqlInput");
    m_x = stream.readDouble();
    m_y = stream.readDouble();
    m_typeName = typeName;
}
项目:pljava    文件Point.java   
@Override
public void readsql(sqlInput stream,String typeName) throws sqlException {
    s_logger.info(typeName + " from sqlInput");
    m_x = stream.readDouble();
    m_y = stream.readDouble();
    m_typeName = typeName;
}
项目:power-matchmaker    文件mungeProcess.java   
/**
 * This is the position offset for different child types. The types are
 * broken into {@link sqlInputStep}s,{@link mungeResultStep}s,and the rest
 * of the munge steps.
 */
public int mungeProcessChildPositionOffset(Class<? extends SPObject> childType) {
    if (mungeResultStep.class.isAssignableFrom(childType)) {
        return 0;
    }
       if (sqlInput.class.isAssignableFrom(childType)) return (resultStep == null? 0 : 1);
       if (mungeStep.class.isAssignableFrom(childType)) {
        return getInputSteps().size() + (resultStep == null? 0 : 1);
       }
       throw new IllegalArgumentException(childType.getName() + 
               " is not a valid child type of " + getClass().getName());
   }
项目:In-the-Box-Fork    文件sqlDataTest.java   
/**
 * Test method for {@link java.sql.sqlData#readsql(java.sql.sqlInput,java.lang.String)}.
 */
@TestTargetNew(
  level = TestLevel.NOT_FEASIBLE,notes = "",method = "readsql",args = {sqlInput.class,String.class}
    )
public void testReadsql() {
    fail("Not yet implemented");
}
项目:pljava-udt-type-extension    文件RationalUDT.java   
/**
 * Read object from sqlInput stream.
 */
public void readsql(sqlInput stream,String typeName) throws sqlException {
    long n = stream.readLong();
    long d = stream.readLong();
    this.value = new Rational(n,d);
    this.typeName = typeName;
}
项目:pljava-udt-type-extension    文件ComplexUDT.java   
/**
 * Read object from sqlInput stream.
 */
public void readsql(sqlInput stream,String typeName) throws sqlException {
    double re = stream.readDouble();
    double im = stream.readDouble();
    this.value = new Complex(re,im);
    this.typeName = typeName;
}
项目:cn1    文件sqlInputImpltest.java   
public void readsql(sqlInput stream,String typeName)
        throws sqlException {
    firstAttribute = stream.readString();
    secondAttribute = stream.readBoolean();
    thirdAttribute = stream.readString();
    fourthAttribute = stream.readInt();
}
项目:freeVM    文件sqlInputImpltest.java   
public void readsql(sqlInput stream,String typeName)
        throws sqlException {
    firstAttribute = stream.readString();
    secondAttribute = stream.readBoolean();
    thirdAttribute = stream.readString();
    fourthAttribute = stream.readInt();
}
项目:gemfirexd-oss    文件SamplesqlData.java   
public void readsql( sqlInput in,String typeName ) throws sqlException
{
    _data = in.readBytes();
}
项目:pljava    文件UDTScalarIOTest.java   
@Function(effects=IMMUTABLE,String typeName) throws sqlException
{
    m_typeName = typeName;

    if ( ! s_bigdec.equals(stream.readBigDecimal()) )
        throw new sqlException("BigDecimal mismatch");
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    InputStream is = stream.readBinaryStream();
    try
    {
        for ( int b ; -1 != (b = is.read()) ; )
            baos.write(b);
    }
    catch ( IOException e )
    {
        throw new sqlException("Reading binary stream","58030",e);
    }
    if ( ! Arrays.equals(s_utfgedicht,baos.toByteArray()) )
        throw new sqlException("binaryStream mismatch");
    if ( s_bool != stream.readBoolean() )
        throw new sqlException("boolean mismatch");
    if ( s_byte != stream.readByte() )
        throw new sqlException("byte mismatch");
    if ( ! Arrays.equals(s_utfgedicht,stream.readBytes()) )
        throw new sqlException("bytes mismatch");
    String charstream = new Scanner(stream.readCharacterStream())
        .useDelimiter("\\A").next();
    if ( ! s_gedicht.equals(charstream) )
        throw new sqlException("characterStream mismatch");
    if ( ! s_date.equals(stream.readDate()) )
        throw new sqlException("date mismatch");
    if ( s_double != stream.readDouble() )
        throw new sqlException("double mismatch");
    if ( s_float != stream.readFloat() )
        throw new sqlException("float mismatch");
    if ( s_int != stream.readInt() )
        throw new sqlException("int mismatch");
    if ( s_long != stream.readLong() )
        throw new sqlException("long mismatch");
    if ( s_short != stream.readShort() )
        throw new sqlException("short mismatch");
    if ( ! s_gedicht.equals(stream.readString()) )
        throw new sqlException("string mismatch");
    if ( ! s_time.equals(stream.readTime()) )
        throw new sqlException("time mismatch");
    if ( ! s_timestamp.equals(stream.readTimestamp()) )
        throw new sqlException("timestamp mismatch");
    if ( ! s_url.equals(stream.readURL()) )
        throw new sqlException("url mismatch");
}
项目:pljava    文件IntWithMod.java   
@Function(effects=IMMUTABLE,String typeName) throws sqlException {
    m_value = stream.readInt();
    m_typeName = typeName;
}
项目: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());
}
项目:GemFireLite    文件JDBCUtils.java   
public static final <T> T wasNull(sqlInput stream,T value) throws sqlException
{
  return stream.wasNull() ? null : value;
}
项目:cn1    文件SerialStructTest.java   
public void readsql(sqlInput stream,String type) throws sqlException {
    sql_type = type;
    first = stream.readString();
    last = stream.readString();
}
项目:cn1    文件SerialStructTest.java   
public void readsql(sqlInput stream,String type) throws sqlException {
    sql_type = type;
    id = stream.readInt();
    name = (Name) stream.readobject();
}
项目:cn1    文件SerialArrayTest.java   
public void readsql(sqlInput stream,String typeName)
        throws sqlException {
    return;
}
项目:freeVM    文件SerialStructTest.java   
public void readsql(sqlInput stream,String type) throws sqlException {
    sql_type = type;
    first = stream.readString();
    last = stream.readString();
}
项目:freeVM    文件SerialStructTest.java   
public void readsql(sqlInput stream,String type) throws sqlException {
    sql_type = type;
    id = stream.readInt();
    name = (Name) stream.readobject();
}
项目:freeVM    文件SerialArrayTest.java   
public void readsql(sqlInput stream,String typeName)
        throws sqlException {
    return;
}
项目:couchbase-to-oracle    文件CouchbaseViewer.java   
public void readsql(sqlInput stream,String typeName) throws sqlException {
    sql_type = typeName;
    key = stream.readBigDecimal();      
}
项目:spliceengine    文件SamplesqlData.java   
public void readsql( sqlInput in,String typeName ) throws sqlException
{
    _data = in.readBytes();
}

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。