OmniSciDB  2e3a973ef4
Public Member Functions | Private Member Functions | Private Attributes | List of all members
com.omnisci.jdbc.OmniSciArray Class Reference
+ Inheritance diagram for com.omnisci.jdbc.OmniSciArray:
+ Collaboration diagram for com.omnisci.jdbc.OmniSciArray:

Public Member Functions

 OmniSciArray (TDatumType type, Object[] elements) throws SQLException
 
String getBaseTypeName () throws SQLException
 
int getBaseType () throws SQLException
 
Object getArray () throws SQLException
 
Object getArray (long start, int size) throws SQLException
 
ResultSet getResultSet () throws SQLException
 
ResultSet getResultSet (long start, int size) throws SQLException
 
void free () throws SQLException
 
String toString ()
 
ResultSet getResultSet (long start, int size, Map< String, Class<?>> map) throws SQLException
 
ResultSet getResultSet (Map< String, Class<?>> map) throws SQLException
 
Object getArray (long start, int size, Map< String, Class<?>> map) throws SQLException
 
Object getArray (Map< String, Class<?>> map) throws SQLException
 

Private Member Functions

void checkSize (int start, int size) throws SQLException
 
void checkClass (Class<?> given, Class<?> expected) throws SQLException
 

Private Attributes

TDatumType type
 
Object [] elements
 

Detailed Description

Definition at line 14 of file OmniSciArray.java.

Constructor & Destructor Documentation

◆ OmniSciArray()

com.omnisci.jdbc.OmniSciArray.OmniSciArray ( TDatumType  type,
Object []  elements 
) throws SQLException
inline

Definition at line 18 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciArray.checkClass(), Double, com.omnisci.jdbc.OmniSciArray.elements, and com.omnisci.jdbc.OmniSciArray.type.

18  {
19  if (elements == null) {
20  throw new SQLException("Elements[] cannot be null");
21  }
22  this.type = type;
23  this.elements = elements;
24  Class<?> elements_class = elements.getClass().getComponentType();
25  switch (type) {
26  case TINYINT:
27  checkClass(elements_class, Byte.class);
28  break;
29  case SMALLINT:
30  checkClass(elements_class, Short.class);
31  break;
32  case INT:
33  checkClass(elements_class, Integer.class);
34  break;
35  case BIGINT:
36  checkClass(elements_class, Long.class);
37  break;
38  case BOOL:
39  checkClass(elements_class, Boolean.class);
40  break;
41  case TIME:
42  checkClass(elements_class, java.sql.Time.class);
43  break;
44  case TIMESTAMP:
45  checkClass(elements_class, java.sql.Timestamp.class);
46  break;
47  case DATE:
48  checkClass(elements_class, java.sql.Date.class);
49  break;
50  case FLOAT:
51  checkClass(elements_class, Float.class);
52  break;
53  case DECIMAL:
54  checkClass(elements_class, BigDecimal.class);
55  break;
56  case DOUBLE:
57  checkClass(elements_class, Double.class);
58  break;
59  case STR:
60  case POINT:
61  case LINESTRING:
62  case POLYGON:
63  case MULTIPOLYGON:
64  checkClass(elements_class, String.class);
65  break;
66  default:
67  throw new AssertionError(type.toString());
68  }
69  }
ExpressionRangeType::Double
import_export::FileType::POLYGON
com.omnisci.jdbc.OmniSciArray.checkClass
void checkClass(Class<?> given, Class<?> expected)
Definition: OmniSciArray.java:286
ExpressionRangeType::Integer
ExpressionRangeType::Float
+ Here is the call graph for this function:

Member Function Documentation

◆ checkClass()

void com.omnisci.jdbc.OmniSciArray.checkClass ( Class<?>  given,
Class<?>  expected 
) throws SQLException
inlineprivate

Definition at line 286 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciArray.getBaseTypeName().

Referenced by com.omnisci.jdbc.OmniSciArray.OmniSciArray().

286  {
287  if (!expected.isAssignableFrom(given)) {
288  throw new SQLException("For array of " + getBaseTypeName() + ", elements of type "
289  + expected + " are expected. Got " + given + " instead");
290  }
291  }
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ checkSize()

void com.omnisci.jdbc.OmniSciArray.checkSize ( int  start,
int  size 
) throws SQLException
inlineprivate

Definition at line 278 of file OmniSciArray.java.

Referenced by com.omnisci.jdbc.OmniSciArray.getArray(), and com.omnisci.jdbc.OmniSciArray.getResultSet().

278  {
279  if (start < 0 || start >= elements.length || start + size > elements.length) {
280  throw new SQLException("Array length = " + Integer.toString(elements.length)
281  + ", slice start index = " + Integer.toString(start)
282  + ", slice length = " + Integer.toString(size));
283  }
284  }
ExpressionRangeType::Integer
+ Here is the caller graph for this function:

◆ free()

void com.omnisci.jdbc.OmniSciArray.free ( ) throws SQLException
inline

Definition at line 204 of file OmniSciArray.java.

204  {
205  elements = null;
206  }

◆ getArray() [1/4]

Object com.omnisci.jdbc.OmniSciArray.getArray ( ) throws SQLException
inline

Definition at line 82 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciArray.elements.

82  {
83  return elements;
84  }

◆ getArray() [2/4]

Object com.omnisci.jdbc.OmniSciArray.getArray ( long  start,
int  size 
) throws SQLException
inline

Definition at line 87 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciArray.checkSize().

87  {
88  checkSize(toIntExact(start), size);
89  return Arrays.copyOfRange(elements, toIntExact(start), size);
90  }
com.omnisci.jdbc.OmniSciArray.checkSize
void checkSize(int start, int size)
Definition: OmniSciArray.java:278
+ Here is the call graph for this function:

◆ getArray() [3/4]

Object com.omnisci.jdbc.OmniSciArray.getArray ( long  start,
int  size,
Map< String, Class<?>>  map 
) throws SQLException
inline

Definition at line 262 of file OmniSciArray.java.

263  {
264  throw new UnsupportedOperationException("Not supported yet,"
265  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
266  + " class:" + new Throwable().getStackTrace()[0].getClassName()
267  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
268  }

◆ getArray() [4/4]

Object com.omnisci.jdbc.OmniSciArray.getArray ( Map< String, Class<?>>  map) throws SQLException
inline

Definition at line 271 of file OmniSciArray.java.

271  {
272  throw new UnsupportedOperationException("Not supported yet,"
273  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
274  + " class:" + new Throwable().getStackTrace()[0].getClassName()
275  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
276  }

◆ getBaseType()

int com.omnisci.jdbc.OmniSciArray.getBaseType ( ) throws SQLException
inline

Definition at line 77 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciType.toJava().

77  {
78  return OmniSciType.toJava(type);
79  }
+ Here is the call graph for this function:

◆ getBaseTypeName()

String com.omnisci.jdbc.OmniSciArray.getBaseTypeName ( ) throws SQLException
inline

Definition at line 72 of file OmniSciArray.java.

Referenced by com.omnisci.jdbc.OmniSciArray.checkClass().

72  {
73  return type.name();
74  }
+ Here is the caller graph for this function:

◆ getResultSet() [1/4]

ResultSet com.omnisci.jdbc.OmniSciArray.getResultSet ( ) throws SQLException
inline

Definition at line 93 of file OmniSciArray.java.

93  {
94  return getResultSet(0, elements.length);
95  }

◆ getResultSet() [2/4]

ResultSet com.omnisci.jdbc.OmniSciArray.getResultSet ( long  start,
int  size 
) throws SQLException
inline

Definition at line 98 of file OmniSciArray.java.

References com.omnisci.jdbc.OmniSciArray.checkSize(), Double, and run_benchmark_import.result.

98  {
99  checkSize(toIntExact(start), size);
100 
101  ArrayList<TColumnType> columnTypes = new ArrayList<>(2);
102  TTypeInfo idxType =
103  new TTypeInfo(TDatumType.BIGINT, TEncodingType.NONE, false, false, 0, 0, 0);
104  columnTypes.add(new TColumnType("INDEX", idxType, false, "", false, false, 0));
105  // @NOTE(Max): The problem here is that it's hard to know precision and scale.
106  // But it looks like we don't use those anywhere in ResultSet ???
107  int precision = (type == TDatumType.TIMESTAMP || type == TDatumType.TIME
108  || type == TDatumType.DATE
109  ? 3
110  : 0);
111  TTypeInfo valueType =
112  new TTypeInfo(type, TEncodingType.NONE, true, false, precision, 0, 0);
113  columnTypes.add(new TColumnType("VALUE", valueType, false, "", false, false, 1));
114 
115  Long[] indexes = new Long[size];
116  // indexes in SQL arrays start from 1
117  for (int i = 0; i < size; ++i) {
118  indexes[i] = (long) (i + 1);
119  }
120  TColumnData idxData = new TColumnData(Arrays.asList(indexes), null, null, null);
121  ArrayList<Boolean> idxNulls = new ArrayList<>(size);
122  for (int i = 0; i < size; ++i) {
123  idxNulls.add(Boolean.FALSE);
124  }
125 
126  TColumnData valuesData;
127  Long[] int_values = new Long[size];
128  Double[] real_values = new Double[size];
129  String[] string_values = new String[size];
130  boolean is_real = false, is_string = false;
131  ArrayList<Boolean> valueNulls = new ArrayList<>(size);
132  for (int i = toIntExact(start); i < start + size; ++i) {
133  if (elements[i] == null) {
134  valueNulls.add(true);
135  } else {
136  valueNulls.add(false);
137  switch (type) {
138  case TINYINT:
139  int_values[i] = ((Byte) elements[i]).longValue();
140  break;
141  case SMALLINT:
142  int_values[i] = ((Short) elements[i]).longValue();
143  break;
144  case INT:
145  int_values[i] = ((Integer) elements[i]).longValue();
146  break;
147  case BIGINT:
148  int_values[i] = (Long) elements[i];
149  break;
150  case BOOL:
151  int_values[i] = elements[i] == Boolean.TRUE ? 1l : 0l;
152  break;
153  case TIME:
154  int_values[i] = ((Time) elements[i]).getTime();
155  break;
156  case TIMESTAMP:
157  int_values[i] = ((Timestamp) elements[i]).getTime();
158  break;
159  case DATE:
160  int_values[i] = ((Date) elements[i]).getTime();
161  break;
162  case FLOAT:
163  is_real = true;
164  real_values[i] = ((Float) elements[i]).doubleValue();
165  break;
166  case DECIMAL:
167  is_real = true;
168  real_values[i] = ((BigDecimal) elements[i]).doubleValue();
169  break;
170  case DOUBLE:
171  is_real = true;
172  real_values[i] = (Double) elements[i];
173  break;
174  case STR:
175  case POINT:
176  case LINESTRING:
177  case POLYGON:
178  case MULTIPOLYGON:
179  is_string = true;
180  string_values[i] = (String) elements[i];
181  break;
182  default:
183  throw new AssertionError(type.toString());
184  }
185  }
186  }
187  if (is_real) {
188  valuesData = new TColumnData(null, Arrays.asList(real_values), null, null);
189  } else if (is_string) {
190  valuesData = new TColumnData(null, null, Arrays.asList(string_values), null);
191  } else {
192  valuesData = new TColumnData(Arrays.asList(int_values), null, null, null);
193  }
194 
195  ArrayList<TColumn> columns = new ArrayList<>(2);
196  columns.add(new TColumn(idxData, idxNulls));
197  columns.add(new TColumn(valuesData, valueNulls));
198  TRowSet rowSet = new TRowSet(columnTypes, null, columns, true);
199  TQueryResult result = new TQueryResult(rowSet, 0, 0, "", "", true, TQueryType.READ);
200  return new OmniSciResultSet(result, "");
201  }
ExpressionRangeType::Double
import_export::FileType::POLYGON
com.omnisci.jdbc.OmniSciArray.checkSize
void checkSize(int start, int size)
Definition: OmniSciArray.java:278
ExpressionRangeType::Integer
ExpressionRangeType::Float
run_benchmark_import.result
dictionary result
Definition: run_benchmark_import.py:441
+ Here is the call graph for this function:

◆ getResultSet() [3/4]

ResultSet com.omnisci.jdbc.OmniSciArray.getResultSet ( long  start,
int  size,
Map< String, Class<?>>  map 
) throws SQLException
inline

Definition at line 245 of file OmniSciArray.java.

246  {
247  throw new UnsupportedOperationException("Not supported yet,"
248  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
249  + " class:" + new Throwable().getStackTrace()[0].getClassName()
250  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
251  }

◆ getResultSet() [4/4]

ResultSet com.omnisci.jdbc.OmniSciArray.getResultSet ( Map< String, Class<?>>  map) throws SQLException
inline

Definition at line 254 of file OmniSciArray.java.

254  {
255  throw new UnsupportedOperationException("Not supported yet,"
256  + " line:" + new Throwable().getStackTrace()[0].getLineNumber()
257  + " class:" + new Throwable().getStackTrace()[0].getClassName()
258  + " method:" + new Throwable().getStackTrace()[0].getMethodName());
259  }

◆ toString()

String com.omnisci.jdbc.OmniSciArray.toString ( )
inline

Definition at line 209 of file OmniSciArray.java.

References File_Namespace.append().

209  {
210  if (elements == null) {
211  return "NULL";
212  } else {
213  switch (type) {
214  case STR:
215  case POINT:
216  case LINESTRING:
217  case POLYGON:
218  case MULTIPOLYGON:
219  case TIME:
220  case TIMESTAMP:
221  case DATE: {
222  StringBuilder sb = new StringBuilder("{");
223  for (Object e : elements) {
224  if (e != null) {
225  sb.append("'").append(e.toString()).append("', ");
226  } else {
227  sb.append("NULL").append(", ");
228  }
229  }
230  if (elements.length > 0) {
231  sb.delete(sb.length() - 2, sb.length());
232  }
233  sb.append("}");
234  return sb.toString();
235  }
236  default: {
237  String arr_str = Arrays.toString(elements);
238  return "{" + arr_str.substring(1, arr_str.length() - 1) + "}";
239  }
240  }
241  }
242  }
import_export::FileType::POLYGON
File_Namespace::append
size_t append(FILE *f, const size_t size, int8_t *buf)
Appends the specified number of bytes to the end of the file f from buf.
Definition: File.cpp:140
+ Here is the call graph for this function:

Member Data Documentation

◆ elements

Object [] com.omnisci.jdbc.OmniSciArray.elements
private

Definition at line 16 of file OmniSciArray.java.

Referenced by com.omnisci.jdbc.OmniSciArray.getArray(), and com.omnisci.jdbc.OmniSciArray.OmniSciArray().

◆ type

TDatumType com.omnisci.jdbc.OmniSciArray.type
private

Definition at line 15 of file OmniSciArray.java.

Referenced by com.omnisci.jdbc.OmniSciArray.OmniSciArray().

The documentation for this class was generated from the following file: