19 package testsuite.clusterj;
21 import java.sql.PreparedStatement;
22 import java.sql.ResultSet;
23 import java.sql.SQLException;
24 import java.util.List;
26 import testsuite.clusterj.model.IdBase;
27 import testsuite.clusterj.model.BinaryTypes;
52 static int NUMBER_OF_INSTANCES = 10;
61 return NUMBER_OF_INSTANCES;
71 Class<? extends IdBase> getModelClass() {
79 int length = (int)Math.pow(2, j);
80 byte[] data =
new byte[length];
82 for (
int d = 0; d < length; ++d) {
83 data[d] = (byte)(i + j + d);
95 protected void verify(
String where, List<Object[]> expecteds, List<Object[]> actuals) {
96 for (
int i = 0;
i < expecteds.size(); ++
i) {
97 Object[] expected = expecteds.get(
i);
98 Object[] actual = actuals.get(
i);
99 errorIfNotEqual(where +
" got failure on id for row " +
i,
i, actual[0]);
100 for (
int j = 1; j < expected.length; ++j) {
102 byte[] expectedColumn = (byte[])(expected)[j];
103 byte[] actualColumn = (byte[])(actual)[j];
104 errorIfNotEqual(where +
" got failure on length of data for row " +
i,
105 expectedColumn.length, actualColumn.length);
106 if (expectedColumn.length == actualColumn.length) {
108 for (j = 0; j < expectedColumn.length; ++j)
109 errorIfNotEqual(where +
" got failure on comparison of data for row "
110 +
i +
" column " + j,
111 expectedColumn[j], actualColumn[j]);
117 public void testWriteJDBCReadNDB() {
122 public void testWriteNDBReadJDBC() {
127 static ColumnDescriptor binary1 =
new ColumnDescriptor
128 (
"binary1",
new InstanceHandler() {
129 public void setFieldValue(IdBase instance, Object value) {
130 ((BinaryTypes)instance).setBinary1((byte[])value);
132 public Object getFieldValue(IdBase instance) {
133 return ((BinaryTypes)instance).getBinary1();
135 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
136 throws SQLException {
137 preparedStatement.setBytes(j, (byte[])value);
139 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
140 return rs.getBytes(j);
144 static ColumnDescriptor binary2 =
new ColumnDescriptor
145 (
"binary2",
new InstanceHandler() {
146 public void setFieldValue(IdBase instance, Object value) {
147 ((BinaryTypes)instance).setBinary2((byte[])value);
149 public Object getFieldValue(IdBase instance) {
150 return ((BinaryTypes)instance).getBinary2();
152 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
153 throws SQLException {
154 preparedStatement.setBytes(j, (byte[])value);
156 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
157 return rs.getBytes(j);
161 static ColumnDescriptor binary4 =
new ColumnDescriptor
162 (
"binary4",
new InstanceHandler() {
163 public void setFieldValue(IdBase instance, Object value) {
164 ((BinaryTypes)instance).setBinary4((byte[])value);
166 public Object getFieldValue(IdBase instance) {
167 return ((BinaryTypes)instance).getBinary4();
169 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
170 throws SQLException {
171 preparedStatement.setBytes(j, (byte[])value);
173 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
174 return rs.getBytes(j);
178 static ColumnDescriptor binary8 =
new ColumnDescriptor
179 (
"binary8",
new InstanceHandler() {
180 public void setFieldValue(IdBase instance, Object value) {
181 ((BinaryTypes)instance).setBinary8((byte[])value);
183 public Object getFieldValue(IdBase instance) {
184 return ((BinaryTypes)instance).getBinary8();
186 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
187 throws SQLException {
188 preparedStatement.setBytes(j, (byte[])value);
190 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
191 return rs.getBytes(j);
195 static ColumnDescriptor binary16 =
new ColumnDescriptor
196 (
"binary16",
new InstanceHandler() {
197 public void setFieldValue(IdBase instance, Object value) {
198 ((BinaryTypes)instance).setBinary16((byte[])value);
200 public Object getFieldValue(IdBase instance) {
201 return ((BinaryTypes)instance).getBinary16();
203 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
204 throws SQLException {
205 preparedStatement.setBytes(j, (byte[])value);
207 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
208 return rs.getBytes(j);
212 static ColumnDescriptor binary32 =
new ColumnDescriptor
213 (
"binary32",
new InstanceHandler() {
214 public void setFieldValue(IdBase instance, Object value) {
215 ((BinaryTypes)instance).setBinary32((byte[])value);
217 public Object getFieldValue(IdBase instance) {
218 return ((BinaryTypes)instance).getBinary32();
220 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
221 throws SQLException {
222 preparedStatement.setBytes(j, (byte[])value);
224 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
225 return rs.getBytes(j);
229 static ColumnDescriptor binary64 =
new ColumnDescriptor
230 (
"binary64",
new InstanceHandler() {
231 public void setFieldValue(IdBase instance, Object value) {
232 ((BinaryTypes)instance).setBinary64((byte[])value);
234 public Object getFieldValue(IdBase instance) {
235 return ((BinaryTypes)instance).getBinary64();
237 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
238 throws SQLException {
239 preparedStatement.setBytes(j, (byte[])value);
241 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
242 return rs.getBytes(j);
246 static ColumnDescriptor binary128 =
new ColumnDescriptor
247 (
"binary128",
new InstanceHandler() {
248 public void setFieldValue(IdBase instance, Object value) {
249 ((BinaryTypes)instance).setBinary128((byte[])value);
251 public Object getFieldValue(IdBase instance) {
252 return ((BinaryTypes)instance).getBinary128();
254 public void setPreparedStatementValue(PreparedStatement preparedStatement,
int j, Object value)
255 throws SQLException {
256 preparedStatement.setBytes(j, (byte[])value);
258 public Object getResultSetValue(ResultSet rs,
int j)
throws SQLException {
259 return rs.getBytes(j);
263 protected static ColumnDescriptor[] columnDescriptors =
new ColumnDescriptor[] {
276 return columnDescriptors;