java.sql.Struct的实例源码

项目：the-vigilantes    文件：JDBC4ResultSet.java   

@SuppressWarnings("unchecked")
public <T> T getobject(int columnIndex,Class<T> type) throws sqlException {
    if (type == null) {
        throw sqlError.createsqlException("Type parameter can not be null",sqlError.sql_STATE_ILLEgal_ARGUMENT,getExceptionInterceptor());
    }

    if (type.equals(Struct.class)) {
        throw new sqlFeatureNotSupportedException();
    } else if (type.equals(RowId.class)) {
        return (T) getRowId(columnIndex);
    } else if (type.equals(NClob.class)) {
        return (T) getNClob(columnIndex);
    } else if (type.equals(sqlXML.class)) {
        return (T) getsqlXML(columnIndex);
    }

    return super.getobject(columnIndex,type);
}

项目：OpenVertretung    文件：JDBC4ResultSet.java   

@SuppressWarnings("unchecked")
public <T> T getobject(int columnIndex,type);
}

项目：lams    文件：JDBC4ResultSet.java   

@SuppressWarnings("unchecked")
public <T> T getobject(int columnIndex,type);
}

项目：lams    文件：JdbcTypeJavaClassMappings.java   

private static ConcurrentHashMap<Class,Integer> buildJdbcJavaClassMappings() {
    ConcurrentHashMap<Class,Integer> jdbcJavaClassMappings = new ConcurrentHashMap<Class,Integer>();

    // these mappings are the ones outlined specifically in the spec
    jdbcJavaClassMappings.put( String.class,Types.VARCHAR );
    jdbcJavaClassMappings.put( BigDecimal.class,Types.NUMERIC );
    jdbcJavaClassMappings.put( Boolean.class,Types.BIT );
    jdbcJavaClassMappings.put( Integer.class,Types.INTEGER );
    jdbcJavaClassMappings.put( Long.class,Types.BIGINT );
    jdbcJavaClassMappings.put( Float.class,Types.REAL );
    jdbcJavaClassMappings.put( Double.class,Types.DOUBLE );
    jdbcJavaClassMappings.put( byte[].class,Types.LONGVARBINARY );
    jdbcJavaClassMappings.put( java.sql.Date.class,Types.DATE );
    jdbcJavaClassMappings.put( Time.class,Types.TIME );
    jdbcJavaClassMappings.put( Timestamp.class,Types.TIMESTAMP );
    jdbcJavaClassMappings.put( Blob.class,Types.BLOB );
    jdbcJavaClassMappings.put( Clob.class,Types.CLOB );
    jdbcJavaClassMappings.put( Array.class,Types.ARRAY );
    jdbcJavaClassMappings.put( Struct.class,Types.STRUCT );
    jdbcJavaClassMappings.put( Ref.class,Types.REF );
    jdbcJavaClassMappings.put( Class.class,Types.JAVA_OBJECT );

    // additional "common sense" registrations
    jdbcJavaClassMappings.put( Character.class,Types.CHAR );
    jdbcJavaClassMappings.put( char[].class,Types.VARCHAR );
    jdbcJavaClassMappings.put( Character[].class,Types.VARCHAR );
    jdbcJavaClassMappings.put( Byte[].class,Types.LONGVARBINARY );
    jdbcJavaClassMappings.put( java.util.Date.class,Types.TIMESTAMP );
    jdbcJavaClassMappings.put( Calendar.class,Types.TIMESTAMP );

    return jdbcJavaClassMappings;
}

项目：ProyectoPacientes    文件：JDBC4ResultSet.java   

@SuppressWarnings("unchecked")
public <T> T getobject(int columnIndex,type);
}

项目：BibliotecaPS    文件：JDBC4ResultSet.java   

@SuppressWarnings("unchecked")
public <T> T getobject(int columnIndex,type);
}

项目：calcite-avatica    文件：AbstractCursor.java   

@Override public Struct getStruct() throws sqlException {
  final Object o = super.getobject();
  if (o == null) {
    return null;
  } else if (o instanceof StructImpl) {
    return (StructImpl) o;
  } else if (o instanceof List) {
    return new StructImpl((List) o);
  } else {
    final List<Object> list = new ArrayList<>();
    for (Accessor fieldAccessor : fieldAccessors) {
      try {
        list.add(fieldAccessor.getobject());
      } catch (sqlException e) {
        throw new RuntimeException(e);
      }
    }
    return new StructImpl(list);
  }
}

项目：NICON    文件：Call.java   

/**
 * Tratar o retorno vido do java
 * @param result
 * @param returnType
 * @return 
 */
@SuppressWarnings("CallToprintstacktrace")
private static Object treatReturn (Object result,int returnType)
{
    Object currectObject = result;
    try
    {
        if (returnType == ARRAY && result instanceof Array)
        {
            Array r = (Array) result;
            currectObject = new ArrayList<> (Arrays.asList((Object [])r.getArray()));
        }
        else if (Types.STRUCT == returnType)
        {
            System.out.println("dbdkj");
            currectObject = ((Struct) result).getAttributes();
        }
    }catch(Exception ex)
    {
        ex.printstacktrace();
    }
    if(currectObject != null)

        System.out.println("RETURN = class{"+currectObject.getClass().getName()+"} | toString = "+currectObject.toString()+"\n");
    return currectObject;
}

项目：the-vigilantes    文件：JDBC4ConnectionWrapper.java   

public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    checkClosed();

    try {
        return ((java.sql.Connection) this.mc).createStruct(typeName,attributes);
    } catch (sqlException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // never reached,but compiler can't tell
}

项目：OpenVertretung    文件：JDBC4ConnectionWrapper.java   

public Struct createStruct(String typeName,but compiler can't tell
}

项目：lams    文件：JDBC4ConnectionWrapper.java   

public Struct createStruct(String typeName,but compiler can't tell
}

项目：ProyectoPacientes    文件：JDBC4ConnectionWrapper.java   

public Struct createStruct(String typeName,but compiler can't tell
}

项目：dswork.jdbc    文件：ConnectionSpy.java   

public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
    try
    {
        return realConnection.createStruct(typeName,attributes);
    }
    catch(sqlException s)
    {
        String methodCall = "createStruct(" + typeName + "," + attributes + ")";
        reportException(methodCall,s,null);
        throw s;
    }
}

项目：BibliotecaPS    文件：JDBC4ConnectionWrapper.java   

public Struct createStruct(String typeName,but compiler can't tell
}

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

@Test(enabled = true)
public void test08() throws Exception {
    Object[] attributes = new Object[]{"Bruce","Wayne",1939,"Batman"};
    Struct s = new StubStruct(sqlType,attributes);
    outImpl.writeStruct(s);
    SerialStruct ss = (SerialStruct) results.get(0);
    assertTrue(Arrays.equals(attributes,(Object[]) ss.getAttributes()));
    assertTrue(sqlType.equals(ss.getsqlTypeName()));
}

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

@test()
public void test11() throws Exception {
    Object[] attributes = new Object[]{"Bruce","Batman"};
    map.put(sqlType,Class.forName("util.SuperHero"));
    Struct struct = new StubStruct(sqlType,attributes);
    Object[] values = {struct};
    sqlInputImpl sqli = new sqlInputImpl(values,map);
    Object o = sqli.readobject();

    assertTrue(hero.equals(o));

}

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

@Test(enabled = true)
public void test08() throws Exception {
    Object[] attributes = new Object[]{"Bruce",(Object[]) ss.getAttributes()));
    assertTrue(sqlType.equals(ss.getsqlTypeName()));
}

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

@test()
public void test11() throws Exception {
    Object[] attributes = new Object[]{"Bruce",map);
    Object o = sqli.readobject();

    assertTrue(hero.equals(o));

}

项目：calcite-avatica    文件：AbstractCursor.java   

@SuppressWarnings("unchecked")
@Override public <T> T getobject(Class<T> clz) throws sqlException {
  // getStruct() is not exposed on Accessor,only AccessorImpl. getobject(Class) is exposed,// so we can make it do the right thing (call getStruct()).
  if (clz.equals(Struct.class)) {
    return (T) getStruct();
  }
  return super.getobject(clz);
}

项目：dremio-oss    文件：DremioConnectionImpl.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
  throwIfClosed();
  try {
    return super.createStruct(typeName,attributes);
  }
  catch (UnsupportedOperationException e) {
    throw new sqlFeatureNotSupportedException(e.getMessage(),e);
  }
}

项目：dswork    文件：ConnectionSpy.java   

public Struct createStruct(String typeName,null);
        throw s;
    }
}

项目：spanner-jdbc    文件：AbstractCloudSpannerConnection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
    return checkClosedAndThrowUnsupportedException();
}

项目：sstore-soft    文件：JDBC4Connection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
    checkClosed();
    throw sqlError.noSupport();
}

项目：burstcoin    文件：FilteredConnection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    return con.createStruct(typeName,attributes);
}

项目：preflex    文件：ConnectionWrapper.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    return conn.createStruct(typeName,attributes);
}

项目：pugtsdb    文件：PugConnection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    return connection.createStruct(typeName,attributes);
}

项目：alfresco-repository    文件：SchemaBootstrap.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
    return wrapped.createStruct(typeName,attributes);
}

项目：mycat-src-1.6.1-RELEASE    文件：SequoiaConnection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes)
        throws sqlException {

    return null;
}

项目：mycat-src-1.6.1-RELEASE    文件：MongoConnection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes)
        throws sqlException {

    return null;
}

项目：tomcat7    文件：Connection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    return null;
}

项目：the-vigilantes    文件：JDBC4FabricMysqLConnectionProxy.java   

public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    transactionBegun();
    return getActiveConnection().createStruct(typeName,attributes);
}

项目：the-vigilantes    文件：JDBC4LoadBalancedMysqLConnection.java   

public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    return this.getJDBC4Connection().createStruct(typeName,attributes);
}

项目：the-vigilantes    文件：JDBC4Connection.java   

public Struct createStruct(String typeName,Object[] attributes) throws sqlException {
    throw sqlError.createsqlFeatureNotSupportedException();
}

项目：the-vigilantes    文件：JDBC4MultiHostMysqLConnection.java   

public Struct createStruct(String typeName,attributes);
}

项目：the-vigilantes    文件：JDBC4ReplicationMysqLConnection.java   

public Struct createStruct(String typeName,attributes);
}

项目：oscm    文件：ConnectionStub.java   

@Override
public Struct createStruct(String typeName,Object[] attributes)
        throws sqlException {

    return null;
}

项目：org.ops4j.pax.transx    文件：ConnectionHandle.java   

@Override
public Struct createStruct(String s,Object[] objects) throws sqlException {
    return call(c -> c.createStruct(s,objects));
}

项目：org.ops4j.pax.transx    文件：ConnectionWrapper.java   

@Override
public Struct createStruct(String s,Object[] objects) throws sqlException {
    return connection.createStruct(s,objects);
}

项目：org.ops4j.pax.transx    文件：StubConnection.java   

/** {@inheritDoc} */
public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
   return null;
}

项目：s-store    文件：JDBC4Connection.java   

@Override
public Struct createStruct(String typeName,Object[] attributes) throws sqlException
{
    checkClosed();
    throw sqlError.noSupport();
}