作者热门文章
- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我已经实现了 java.sql.SQLData
为了使用 ojdbc6 将 UDT 对象绑定(bind)到准备好的语句。现在,我的一些 UDT 包含数组。我现在需要做的是:
class MyType implements SQLData {
public void writeSQL(SQLOutput stream) throws SQLException {
Array array = //...
stream.writeArray(array);
}
}
为了构建 Oracle 数组,我需要一个 JDBC 连接。通常,这样做是这样的:
OracleConnection conn = // ...
Array array = conn.createARRAY("MY_ARRAY_TYPE", new Integer[] { 1, 2, 3 });
但是,在那个 writeSQL(SQLOutput)
方法中,我没有连接。此外,由于难以在简明问题中解释的原因,我无法在 MyType
中维护连接引用。我能以某种方式从 SQLOutput
中提取该连接吗?我想避免使用这样不稳定的结构:
// In ojdbc6, I have observed a private "conn" member in OracleSQLOutput:
Field field = stream.getClass().getDeclaredField("conn");
field.setAccessible(true);
OracleConnection conn = (OracleConnection) field.get(stream);
有什么想法吗?替代方案?
最佳答案
以下是我为解决此问题所做的工作。它不是很漂亮,但它确实有效。
我在实现 SQLData
的类中添加了一个方法,该方法接收 java.sql.Connection
并设置相应的 java.sql.ARRAY
对象。
像这样:
public class MyObject01 implements SQLData {
private String value;
private MyObject02[] details; // do note that details is a java array
// ... also added getters and setters for these two properties
private Array detailsArray;
public void setupArrays(oracle.jdbc.OracleConnection oconn)
throws SQLException
{
detailsArrays = oconn.createARRAY(MyObject02.ORACLE_OBJECT_ARRAY_NAME, getDetails());
// MyObject02.ORACLE_OBJECT_ARRAY_NAME must be the name of the oracle "table of" type name
// Also note that in Oracle you can't use JDBC's default createArray
// since it's not supported. That's why you need to get a OracleConnection
// instance here.
}
@Override
public void writeSQL(Stream stream) throws SQLException {
stream.writeString(getValue());
stream.writeArray(detailsArray); // that's it
}
@Override
public void readSQL(Stream stream) throws SQLException {
setValue(stream.readString());
Array array = stream.readArray();
if (array != null) {
setDetails((MyObject02[])array.getArray());
}
}
这是第一部分。
然后,在过程调用中使用该对象之前,对该对象调用 setupArrays
方法。示例:
public class DB {
public static String executeProc(Connection conn, MyObject01 obj)
throws SQLException
{
CalllableStatement cs = conn.prepareCall(" { ? = call sch.proc(?) }");
cs.registerOutParameter(1, Types.VARCHAR);
obj.setupArrays((oracle.jdbc.Connection)conn);
cs.setObject(2, obj, Types.STRUCT);
cs.executeUpdate();
String ret = cs.getString(1);
cs.close();
return ret;
}
}
当然,在连接后,您需要正确注册您的类型:
Connection conn = DriverManager.getConnection("jdbc:oracle://localhost:1521/XE", "scott", "tiger" );
conn.getTypeMap().put(MyObject01.ORACLE_OBJECT_NAME, MyObject01.class);
conn.getTypeMap().put(MyObject02.ORACLE_OBJECT_NAME, MyObject02.class);
conn.getTypeMap().put(MyObject02.ORACLE_OBJECT_ARRAY_NAME, MyObject02[].class);
希望对您有所帮助。
关于java - 如何在 SQLData.writeSQL() for Oracle 中将 java.sql.Array 写入 java.sql.SQLOutput,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11439543/
我已经实现了 java.sql.SQLData为了使用 ojdbc6 将 UDT 对象绑定(bind)到准备好的语句。现在,我的一些 UDT 包含数组。我现在需要做的是: class MyType i
我是一名优秀的程序员,十分优秀!