58 logger.info(
"In doWork");
60 TTransport transport = null;
62 transport =
new TSocket(
"localhost", 6274);
67 TProtocol protocol =
new TBinaryProtocol(transport);
71 OmniSci.Client client =
new OmniSci.Client(protocol);
73 String session = null;
75 session = client.connect(
"admin",
"HyperInteractive",
"omnisci");
77 logger.info(
"Connected session is " + session);
80 List<TDBInfo> dbs = client.get_databases(session);
82 for (TDBInfo db : dbs) {
83 logger.info(
"db is " + db.toString());
87 List<String>
tables = client.get_tables(session);
89 for (String tab : tables) {
90 logger.info(
"Tables is " + tab);
94 logger.info(
"Version " + client.get_version());
97 TTableDetails table_details = client.get_table_details(session,
"flights");
98 for (TColumnType col : table_details.row_desc) {
99 logger.info(
"col name :" + col.col_name);
100 logger.info(
"\tcol encoding :" + col.col_type.encoding);
101 logger.info(
"\tcol is_array :" + col.col_type.is_array);
102 logger.info(
"\tcol nullable :" + col.col_type.nullable);
107 logger.info(
" -- before query -- ");
109 TQueryResult sql_execute = client.sql_execute(session,
110 "Select uniquecarrier,flightnum from flights LIMIT 3;",
119 logger.info(
" -- after query -- ");
121 logger.info(
"TQueryResult execution time is " + sql_execute.getExecution_time_ms());
122 logger.info(
"TQueryResult is " + sql_execute.toString());
123 logger.info(
"TQueryResult getFieldValue is "
124 + sql_execute.getFieldValue(TQueryResult._Fields.ROW_SET));
126 TRowSet row_set = sql_execute.getRow_set();
127 Object fieldValue = sql_execute.getFieldValue(TQueryResult._Fields.ROW_SET);
128 logger.info(
"fieldValue " + fieldValue);
130 logger.info(
"TRowSet is " + row_set.toString());
132 logger.info(
"Get rows size " + row_set.getRowsSize());
133 logger.info(
"Get col size " + row_set.getRowsSize());
135 List<TRow> rows = row_set.getRows();
137 for (TRow row : rows) {
138 List<TDatum> cols = row.getCols();
140 for (TDatum dat : cols) {
141 logger.info(
"ROW " +
count +
" " + dat.getFieldValue(TDatum._Fields.VAL));
147 List<TColumn> columns = row_set.getColumns();
149 logger.info(
"columns " + columns);
151 for (TColumn col : columns) {
152 TColumnData data = col.getData();
154 logger.info(
"COL " + count +
" " + data.toString());
159 int dash = client.create_dashboard(session,
"test1",
"state",
"image",
"metadata");
161 logger.info(
"dash id is " + dash);
164 client.create_dashboard(session,
"test2",
"state2",
"image2",
"metadata2");
166 logger.info(
"dash2 id is " + dash2);
168 client.replace_dashboard(
169 session, dash2,
"test3",
"mapd",
"state3",
"image3",
"metadata3");
171 logger.info(
"replaced");
174 logger.info(
"Trying to disconnect session " + session);
175 client.disconnect(session);
176 }
catch (TOmniSciException ex) {
177 logger.error(ex.toString());
178 ex.printStackTrace();
179 }
catch (TException ex) {
180 logger.error(ex.toString());
181 ex.printStackTrace();
182 }
catch (Exception ex) {
183 logger.error(ex.toString());
184 ex.printStackTrace();
187 logger.info(
"Connection Ended");