Skip to content

Commit 5733b35

Browse files
weisun123weisun123
committed
Update Prepare.java
1 parent ad03a42 commit 5733b35

File tree

1 file changed

+85
-0
lines changed

1 file changed

+85
-0
lines changed

‎test/com/xxdb/Prepare.java‎

Lines changed: 85 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -158,6 +158,16 @@ public static void Preparedata_keyTable(long count) throws IOException {
158158
conn.run(script);
159159
}
160160

161+
public static void Prepare_streamTable(String tableName) throws IOException {
162+
String script = "login(`admin, `123456); \n" +
163+
"colNames = `boolv`charv`shortv`intv`longv`doublev`floatv`datev`monthv`timev`minutev`secondv`datetimev`timestampv`nanotimev`nanotimestampv`symbolv`stringv`datehourv`uuidv`ippaddrv`int128v`blobv`pointv`complexv`decimal32v`decimal64v`decimal128v ;\n" +
164+
"colTypes=[BOOL,CHAR,SHORT,INT,LONG,DOUBLE,FLOAT,DATE,MONTH,TIME,MINUTE,SECOND,DATETIME,TIMESTAMP,NANOTIME,NANOTIMESTAMP,SYMBOL,STRING,DATEHOUR,UUID,IPADDR,INT128,BLOB,POINT,COMPLEX,DECIMAL32(2),DECIMAL64(7),DECIMAL128(18)]\n" +
165+
"share streamTable(1:0,colNames,colTypes) as " + tableName +";\n" ;
166+
DBConnection conn = new DBConnection();
167+
conn.connect(HOST,PORT,"admin","123456");
168+
conn.run(script);
169+
}
170+
161171
public static void Preparedata1(long count) throws IOException {
162172
String script = "login(`admin, `123456); \n" +
163173
"n="+count+";\n" +
@@ -233,6 +243,81 @@ public static void Preparedata_array(long count1,long count2) throws IOException
233243
conn.run(script1);
234244
}
235245

246+
public static void Preparedata_streamTable_array(long count1,long count2) throws IOException {
247+
String script1 = "login(`admin, `123456); \n"+
248+
"n="+count1+";\n" +
249+
"m="+count2+";\n" +
250+
"rows = ceil(double(n)/m)\n" +
251+
"id = take(1..300000, rows) ;\n" +
252+
"cbool = array(BOOL[]).append!(cut(take([true, false, NULL], n), m))\n" +
253+
"cchar = array(CHAR[]).append!(cut(take(char(-100..100 join NULL), n), m))\n" +
254+
"cshort = array(SHORT[]).append!(cut(take(short(-100..100 join NULL), n), m))\n" +
255+
"cint = array(INT[]).append!(cut(take(-100..100 join NULL, n), m))\n" +
256+
"clong = array(LONG[]).append!(cut(take(long(-100..100 join NULL), n), m))\n" +
257+
"cdouble = array(DOUBLE[]).append!(cut(take(-100..100 join NULL, n) + 0.254, m))\n" +
258+
"cfloat = array(FLOAT[]).append!(cut(take(-100..100 join NULL, n) + 0.254f, m))\n" +
259+
"cdate = array(DATE[]).append!(cut(take(2012.01.01..2012.02.29, n), m))\n" +
260+
"cmonth = array(MONTH[]).append!(cut(take(2012.01M..2013.12M, n), m))\n" +
261+
"ctime = array(TIME[]).append!(cut(take(09:00:00.000 + 0..99 * 1000, n), m))\n" +
262+
"cminute = array(MINUTE[]).append!(cut(take(09:00m..15:59m, n), m))\n" +
263+
"csecond = array(SECOND[]).append!(cut(take(09:00:00 + 0..999, n), m))\n" +
264+
"cdatetime = array(DATETIME[]).append!(cut(take(2012.01.01T09:00:00 + 0..999, n), m))\n" +
265+
"ctimestamp = array(TIMESTAMP[]).append!(cut(take(2012.01.01T09:00:00.000 + 0..999 * 1000, n), m))\n" +
266+
"cnanotime =array(NANOTIME[]).append!(cut(take(09:00:00.000000000 + 0..999 * 1000000000, n), m))\n" +
267+
"cnanotimestamp = array(NANOTIMESTAMP[]).append!(cut(take(2012.01.01T09:00:00.000000000 + 0..999 * 1000000000, n), m))\n" +
268+
"cuuid = array(UUID[]).append!(cut(take(uuid([\"5d212a78-cc48-e3b1-4235-b4d91473ee87\", \"5d212a78-cc48-e3b1-4235-b4d91473ee88\", \"5d212a78-cc48-e3b1-4235-b4d91473ee89\", \"\"]), n), m))\n" +
269+
"cdatehour = array(DATEHOUR[]).append!(cut(take(datehour(1..10 join NULL), n), m))\n" +
270+
"cipaddr = array(IPADDR[]).append!(cut(take(ipaddr([\"192.168.100.10\", \"192.168.100.11\", \"192.168.100.14\", \"\"]), n), m))\n" +
271+
"cint128 = array(INT128[]).append!(cut(take(int128([\"e1671797c52e15f763380b45e841ec32\", \"e1671797c52e15f763380b45e841ec33\", \"e1671797c52e15f763380b45e841ec35\", \"\"]), n), m))\n" +
272+
"ccomplex = array( COMPLEX[]).append!(cut(rand(complex(rand(100, 1000), rand(100, 1000)) join NULL, n), m))\n" +
273+
"cpoint = array(POINT[]).append!(cut(rand(point(rand(100, 1000), rand(100, 1000)) join NULL, n), m))\n" +
274+
"cdecimal32 = array(DECIMAL32(2)[]).append!(cut(decimal32(take(-100..100 join NULL, n) + 0.254, 3), m))\n" +
275+
"cdecimal64 = array(DECIMAL64(7)[]).append!(cut(decimal64(take(-100..100 join NULL, n) + 0.25, 4), m))\n" +
276+
"cdecimal128 = array(DECIMAL128(19)[]).append!(cut(decimal128(take(-100..100 join NULL, n) + 0.25, 5), m))\n" +
277+
"share streamTable(1000000:0, `id`cbool`cchar`cshort`cint`clong`cdouble`cfloat`cdate`cmonth`ctime`cminute`csecond`cdatetime`ctimestamp`cnanotime`cnanotimestamp`cdatehour`cuuid`cipaddr`cint128`cpoint`ccomplex`cdecimal32`cdecimal64`cdecimal128, [INT,BOOL[],CHAR[],SHORT[],INT[],LONG[],DOUBLE[],FLOAT[],DATE[],MONTH[],TIME[],MINUTE[],SECOND[],DATETIME[],TIMESTAMP[],NANOTIME[],NANOTIMESTAMP[], DATEHOUR[],UUID[],IPADDR[],INT128[],POINT[],COMPLEX[],DECIMAL32(2)[],DECIMAL64(7)[],DECIMAL128(19)[]]) as Receive;\n" +
278+
"share streamTable(id, cbool, cchar, cshort, cint, clong, cdouble, cfloat, cdate, cmonth, ctime, cminute, csecond, cdatetime, ctimestamp, cnanotime, cnanotimestamp, cdatehour, cuuid, cipaddr, cint128, cpoint, ccomplex, cdecimal32, cdecimal64, cdecimal128) as Trades;\n" ;
279+
DBConnection conn = new DBConnection();
280+
conn.connect(HOST,PORT,"admin","123456");
281+
conn.run(script1);
282+
}
283+
284+
public static void PrepareStreamTable_StreamDeserializer_array_allDataType() throws IOException {
285+
String script = "share streamTable(10000:0, `permno`sym`blob`boolv`charv`shortv`intv`longv`doublev`floatv`datev`monthv`timev`minutev`secondv`datetimev`timestampv`nanotimev`nanotimestampv`datehourv`uuidv`ipaddrv`int128v`complexv`pointv, [TIMESTAMP,SYMBOL,BLOB,BOOL[],CHAR[],SHORT[],INT[],LONG[],DOUBLE[],FLOAT[],DATE[],MONTH[],TIME[],MINUTE[],SECOND[],DATETIME[],TIMESTAMP[],NANOTIME[],NANOTIMESTAMP[], DATEHOUR[],UUID[],IPADDR[],INT128[],COMPLEX[],POINT[]]) as outTables;\n" +
286+
"permno = take(1..1000,1000); \n" +
287+
"timestampv = 2018.12.01T01:21:23.000 + 1..1000; \n" +
288+
"dateType_INT = array(INT[]).append!(cut(take(-100..100 join NULL, 1000*10), 10)); \n" +
289+
"dateType_BOOL = array(BOOL[]).append!(cut(take([true, false, NULL], 1000*10), 10)); \n" +
290+
"dateType_CHAR = array(CHAR[]).append!(cut(take(char(-10..10 join NULL), 1000*10), 10)); \n" +
291+
"dateType_SHORT = array(SHORT[]).append!(cut(take(short(-100..100 join NULL), 1000*10), 10)); \n" +
292+
"dateType_LONG = array(LONG[]).append!(cut(take(long(-100..100 join NULL), 1000*10), 10)); \n" + "" +
293+
"dateType_DOUBLE = array(DOUBLE[]).append!(cut(take(-100..100 join NULL, 1000*10) + 0.254, 10)); \n" +
294+
"dateType_FLOAT = array(FLOAT[]).append!(cut(take(-100..100 join NULL, 1000*10) + 0.254f, 10)); \n" +
295+
"dateType_DATE = array(DATE[]).append!(cut(take(2012.01.01..2012.02.29, 1000*10), 10)); \n" +
296+
"dateType_MONTH = array(MONTH[]).append!(cut(take(2012.01M..2013.12M, 1000*10), 10)); \n" +
297+
"dateType_TIME = array(TIME[]).append!(cut(take(09:00:00.000 + 0..99 * 1000, 1000*10), 10)); \n" +
298+
"dateType_MINUTE = array(MINUTE[]).append!(cut(take(09:00m..15:59m, 1000*10), 10)); \n" +
299+
"dateType_SECOND = array(SECOND[]).append!(cut(take(09:00:00 + 0..999, 1000*10), 10)); \n" +
300+
"dateType_DATETIME = array(DATETIME[]).append!(cut(take(2012.01.01T09:00:00 + 0..999, 1000*10), 10)); \n" +
301+
"dateType_TIMESTAMP = array(TIMESTAMP[]).append!(cut(take(2012.01.01T09:00:00.000 + 0..999 * 1000, 1000*10), 10)); \n" +
302+
"dateType_NANOTIME = array(NANOTIME[]).append!(cut(take(09:00:00.000000000 + 0..999 * 1000000000, 1000*10), 10)); \n" +
303+
"dateType_NANOTIMESTAMP = array(NANOTIMESTAMP[]).append!(cut(take(2012.01.01T09:00:00.000000000 + 0..999 * 1000000000, 1000*10), 10)); \n" +
304+
"dateType_UUID = array(UUID[]).append!(cut(take(uuid([\"5d212a78-cc48-e3b1-4235-b4d91473ee87\", \"5d212a78-cc48-e3b1-4235-b4d91473ee88\", \"5d212a78-cc48-e3b1-4235-b4d91473ee89\", \"\"]), 1000*10), 10)); \n" +
305+
"dateType_DATEHOUR = array(DATEHOUR[]).append!(cut(take(datehour(1..10 join NULL), 1000*10), 10)); \n" +
306+
"dateType_IPADDR = array(IPADDR[]).append!(cut(take(ipaddr([\"192.168.100.10\", \"192.168.100.11\", \"192.168.100.14\", \"\"]), 1000*10), 10)); \n" +
307+
"dateType_INT128 = array(INT128[]).append!(cut(take(int128([\"e1671797c52e15f763380b45e841ec32\", \"e1671797c52e15f763380b45e841ec33\", \"e1671797c52e15f763380b45e841ec35\", \"\"]), 1000*10), 10)); \n" +
308+
"dateType_COMPLEX = array(COMPLEX[]).append!(cut(rand(complex(rand(100, 1000), rand(100, 1000)) join NULL, 1000*10), 10));; \n" +
309+
"dateType_POINT = array(POINT[]).append!(cut(rand(point(rand(100, 1000), rand(100, 1000)) join NULL, 1000*10), 10)); \n" +
310+
"share table(timestampv as timestamp1,dateType_BOOL as boolv, dateType_CHAR as charv, dateType_SHORT as shortv, dateType_INT as intv, dateType_LONG as longv, dateType_DOUBLE as doublev, dateType_FLOAT as floatv, dateType_DATE as datev, dateType_MONTH as monthv, dateType_TIME as timev, dateType_MINUTE as minutev, dateType_SECOND as secondv, dateType_DATETIME as datetimev, dateType_TIMESTAMP as timestampv, dateType_NANOTIME as nanotimev, dateType_NANOTIMESTAMP as nanotimestampv, dateType_DATEHOUR as datehourv, dateType_UUID as uuidv, dateType_IPADDR as ipaddrv, dateType_INT128 as int128v, dateType_COMPLEX as complexv, dateType_POINT as pointv) as pub_t1;\n" +
311+
"share table(timestampv as timestamp1,dateType_BOOL as boolv, dateType_CHAR as charv, dateType_SHORT as shortv, dateType_INT as intv, dateType_LONG as longv, dateType_DOUBLE as doublev, dateType_FLOAT as floatv, dateType_DATE as datev, dateType_MONTH as monthv, dateType_TIME as timev, dateType_MINUTE as minutev, dateType_SECOND as secondv, dateType_DATETIME as datetimev, dateType_TIMESTAMP as timestampv, dateType_NANOTIME as nanotimev, dateType_NANOTIMESTAMP as nanotimestampv, dateType_DATEHOUR as datehourv, dateType_UUID as uuidv, dateType_IPADDR as ipaddrv, dateType_INT128 as int128v, dateType_COMPLEX as complexv, dateType_POINT as pointv) as pub_t2;\n" +
312+
"d = dict(['msg1','msg2'], [pub_t1, pub_t2]);\n" +
313+
"replay(inputTables=d, outputTables=`outTables, dateColumn=`timestamp1, timeColumn=`timestamp1);\n" +
314+
"share streamTable(1000000:0, `timestamp1`boolv`charv`shortv`intv`longv`doublev`floatv`datev`monthv`timev`minutev`secondv`datetimev`timestampv`nanotimev`nanotimestampv`datehourv`uuidv`ipaddrv`int128v`complexv`pointv, [TIMESTAMP,BOOL[],CHAR[],SHORT[],INT[],LONG[],DOUBLE[],FLOAT[],DATE[],MONTH[],TIME[],MINUTE[],SECOND[],DATETIME[],TIMESTAMP[],NANOTIME[],NANOTIMESTAMP[], DATEHOUR[],UUID[],IPADDR[],INT128[],COMPLEX[],POINT[]]) as sub1;\n" +
315+
"share streamTable(1000000:0, `timestamp1`boolv`charv`shortv`intv`longv`doublev`floatv`datev`monthv`timev`minutev`secondv`datetimev`timestampv`nanotimev`nanotimestampv`datehourv`uuidv`ipaddrv`int128v`complexv`pointv, [TIMESTAMP,BOOL[],CHAR[],SHORT[],INT[],LONG[],DOUBLE[],FLOAT[],DATE[],MONTH[],TIME[],MINUTE[],SECOND[],DATETIME[],TIMESTAMP[],NANOTIME[],NANOTIMESTAMP[], DATEHOUR[],UUID[],IPADDR[],INT128[],COMPLEX[],POINT[]]) as sub2;\n";
316+
DBConnection conn = new DBConnection();
317+
conn.connect(HOST, PORT, "admin", "123456");
318+
conn.run(script);
319+
}
320+
236321
public static void Preparedata_array_keyTable(long count1,long count2) throws IOException {
237322
String script1 = "login(`admin, `123456); \n"+
238323
"n = "+count1+";\n" +

0 commit comments

Comments
 (0)