@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();
}
@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();
}
@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();
}
@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();
}
@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
项目:mongodb-rdbms-sync
文件:O2MSyncEventLog.java
项目:openjdk-jdk10
文件:SuperHero.java
项目:openjdk9
文件:SuperHero.java
项目:jdk8u_jdk
文件:SuperHero.java
项目:lookaside_java-1.8.0-openjdk
文件:SuperHero.java
项目:pljava
文件:VarlenaUDTTest.java
项目:pljava
文件:ComplexTuple.java
项目:pljava
文件:ComplexScalar.java
项目:pljava
文件:Point.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());
}
项目:pljava-udt-type-extension
文件:RationalUDT.java
项目:pljava-udt-type-extension
文件:ComplexUDT.java
项目: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
项目:cn1
文件:SerialStructTest.java
项目:cn1
文件:SerialStructTest.java
项目:cn1
文件:SerialArrayTest.java
项目:freeVM
文件:SerialStructTest.java
项目:freeVM
文件:SerialStructTest.java
项目:freeVM
文件:SerialArrayTest.java
项目:couchbase-to-oracle
文件:CouchbaseViewer.java
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。