|
Миграция с Oracle на PostgreSQL. Передать параметр составного типа в хранимую через jdbс
#38541070
Ссылка:
Ссылка на сообщение:
Ссылка с названием темы:
|
|
|
|
В Oracle, когда надо было передавать в хранимые массивы составных типов делали так:
Создавали оракловый тип:
1.
2.
3.
4.
CREATE OR REPLACE TYPE "TEST.TEST_TYPE" as object (
unid number
, name varchar2 (100 char)
)
И тип таблица от этих типов
1.
CREATE OR REPLACE TYPE "TEST.TEST_TYPE_TAB" as table of TEST.TEST_TYPE
в вызывающем коде делали маппинг этих типов через ORAData
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
141.
142.
143.
144.
145.
146.
147.
public class TestSqlType implements ORAData, ORADataFactory
{
public static final String _SQL_NAME = "TEST.TEST_TYPE";
public static final int _SQL_TYPECODE = OracleTypes.STRUCT;
protected MutableStruct _struct;
private static int[] _sqlType = { 2,12 };
private static ORADataFactory[] _factory = new ORADataFactory[2];
protected static final TestSqlType _TestSqlTypeFactory = new TestSqlType(false);
public static ORADataFactory getORADataFactory()
{ return _TestSqlTypeFactory; }
/* constructor */
protected TestSqlType(boolean init)
{ if(init) _struct = new MutableStruct(new Object[2], _sqlType, _factory); }
public TestSqlType()
{ this(true); }
public TestSqlType(oracle.sql.NUMBER unid, oracle.sql.CHAR name) throws SQLException
{ this(true);
setUnid(unid);
setName(name);
}
/* ORAData interface */
public Datum toDatum(Connection c) throws SQLException
{
return _struct.toDatum(c, _SQL_NAME);
}
/* ORADataFactory interface */
public ORAData create(Datum d, int sqlType) throws SQLException
{ return create(null, d, sqlType); }
protected ORAData create(TestSqlType o, Datum d, int sqlType) throws SQLException
{
if (d == null) return null;
if (o == null) o = new TestSqlType(false);
o._struct = new MutableStruct((STRUCT) d, _sqlType, _factory);
return o;
}
/* accessor methods */
public oracle.sql.NUMBER getUnid() throws SQLException
{ return (oracle.sql.NUMBER) _struct.getOracleAttribute(0); }
public void setUnid(oracle.sql.NUMBER unid) throws SQLException
{ _struct.setOracleAttribute(0, unid); }
public oracle.sql.CHAR getName() throws SQLException
{ return (oracle.sql.CHAR) _struct.getOracleAttribute(1); }
public void setName(oracle.sql.CHAR name) throws SQLException
{ _struct.setOracleAttribute(1, name); }
}
public class TestSqlTypeTab implements ORAData, ORADataFactory
{
public static final String _SQL_NAME = "TEST.TEST_SQL_TYPE_TAB";
public static final int _SQL_TYPECODE = OracleTypes.ARRAY;
MutableArray _array;
private static final TestSqlTypeTab _TestSqlTypeTabFactory = newTestSqlTypeTab();
public static ORADataFactory getORADataFactory()
{ return _TestSqlTypeTabFactory; }
/* constructors */
public TestSqlTypeTab()
{
this((TestSqlType[])null);
}
publicTestSqlTypeTab(TestSqlTypeType[] a)
{
_array = new MutableArray(2002, a, TestSqlType.getORADataFactory());
}
/* ORAData interface */
public Datum toDatum(Connection c) throws SQLException
{
return _array.toDatum(c, _SQL_NAME);
}
/* ORADataFactory interface */
public ORAData create(Datum d, int sqlType) throws SQLException
{
if (d == null) return null;
TestSqlTypeTab a = new TestSqlTypeTab();
a._array = new MutableArray(2002, (ARRAY) d, TestSqlType.getORADataFactory());
return a;
}
public int length() throws SQLException
{
return _array.length();
}
public int getBaseType() throws SQLException
{
return _array.getBaseType();
}
public String getBaseTypeName() throws SQLException
{
return _array.getBaseTypeName();
}
public ArrayDescriptor getDescriptor() throws SQLException
{
return _array.getDescriptor();
}
/* array accessor methods */
public TestSqlType[] getArray() throws SQLException
{
return (TestSqlType[]) _array.getObjectArray(
new TestSqlType[_array.length()]);
}
public void setArray(TestSqlType[] a) throws SQLException
{
_array.setObjectArray(a);
}
public TestSqlType[] getArray(long index, int count) throws SQLException
{
return (TestSqlType[]) _array.getObjectArray(index,
new TestSqlType[_array.sliceLength(index, count)]);
}
public void setArray(TestSqlType[] a, long index) throws SQLException
{
_array.setObjectArray(a, index);
}
public TestSqlType getElement(long index) throws SQLException
{
return (TestSqlType) _array.getObjectElement(index);
}
public void setElement(TestSqlType a, long index) throws SQLException
{
_array.setObjectElement(a, index);
}
}
В результате через jdbc могли передавать параметры со структурой любой сложности
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
conn.setAutoCommit(false);
cs = (OracleCallableStatement)conn.prepareCall(
"BEGIN TEST.PROC_TEST(?); END;");
TestSqlType[] rows = new TestSqlType[2];
rows[0] = new TestSqlType(new NUMBER(1),
new CHAR("name1".getBytes("Cp1251"), chSet));
rows[1] = new TestSqlType(new NUMBER(2),
new CHAR("name2".getBytes("Cp1251"), chSet));
//construct table
TestSqlTypeTab tab = new TestSqlTypeTab(rows);
cs.setORAData(1,tab);
cs.execute();
Есть в PostgreSQL какон нибудь аналог ORAData или что нибудь попроще для реализации таких задач(передачи в качестве параметров хранимой выпуклых структур данных)? |
|
|
