mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-08-28 02:44:59 +00:00
284f62dcb9
* create function, create/drop model; re-introduced limit; added COPY; var(); corr() * review feedback
94 lines
2.9 KiB
Go
94 lines
2.9 KiB
Go
package defs
|
|
|
|
// bulk insert
|
|
var bulkInsertTable = TableTest{
|
|
name: "bulkInsertTable",
|
|
Table: tbl(
|
|
"bulktest",
|
|
srcHdrs(
|
|
srcHdr("_id", fldTypeString),
|
|
srcHdr("id_col", fldTypeID),
|
|
srcHdr("string_col", fldTypeString),
|
|
srcHdr("int_col", fldTypeInt),
|
|
srcHdr("decimal_col", fldTypeDecimal2),
|
|
srcHdr("bool_col", fldTypeBool),
|
|
srcHdr("time_col", fldTypeTimestamp),
|
|
srcHdr("stringset_col", fldTypeStringSet),
|
|
srcHdr("idset_col", fldTypeIDSet),
|
|
),
|
|
),
|
|
SQLTests: nil,
|
|
}
|
|
|
|
var bulkInsert = TableTest{
|
|
name: "bulkInsert",
|
|
SQLTests: []SQLTest{
|
|
{
|
|
name: "timestamp-csv-text",
|
|
SQLs: sqls(
|
|
`BULK INSERT INTO
|
|
bulktest (_id, id_col, string_col, int_col,decimal_col, bool_col, time_col, stringset_col, idset_col)
|
|
map (0 ID, 1 STRING, 2 INT, 3 DECIMAL(2), 4 BOOL, 5 TIMESTAMP, 6 STRINGSET, 7 IDSET)
|
|
transform(@1, @0, @1, @2, @3, @4, @5, @6, @7)
|
|
FROM x'1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset1, 1
|
|
2,TEST2,321,31.2,1,2014-07-15T01:18:46Z,stringset1, 1
|
|
1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset2, 2'
|
|
with
|
|
BATCHSIZE 10000
|
|
format 'CSV'
|
|
input 'STREAM';`,
|
|
),
|
|
ExpHdrs: hdrs(),
|
|
ExpRows: rows(),
|
|
Compare: CompareExactOrdered,
|
|
},
|
|
{
|
|
name: "bulk-insert-assignment-compatibility",
|
|
SQLs: sqls(
|
|
`BULK INSERT INTO
|
|
bulktest (_id, id_col, string_col, int_col,decimal_col, bool_col, time_col, stringset_col, idset_col)
|
|
map (0 ID, 1 STRING, 2 STRING, 3 DECIMAL(2), 4 BOOL, 5 TIMESTAMP, 6 STRINGSET, 7 IDSET)
|
|
transform(@1, @0, @1, @2, @3, @4, @5, @6, @7)
|
|
FROM x'1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset1, 1
|
|
2,TEST2,321,31.2,1,2014-07-15T01:18:46Z,stringset1, 1
|
|
1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset2, 2'
|
|
with
|
|
BATCHSIZE 10000
|
|
format 'CSV'
|
|
input 'STREAM';`,
|
|
),
|
|
ExpErr: "an expression of type 'string' cannot be assigned to type 'int'",
|
|
Compare: CompareExactOrdered,
|
|
},
|
|
{
|
|
name: "bulk-insert-assignment-compatibility-no-transform",
|
|
SQLs: sqls(
|
|
`BULK INSERT INTO
|
|
bulktest (_id, id_col, string_col, int_col,decimal_col, bool_col, time_col, stringset_col, idset_col)
|
|
map (0 ID, 1 ID, 2 STRING, 3 STRING, 4 DECIMAL(2), 5 BOOL, 6 TIMESTAMP, 7 STRINGSET, 8 IDSET)
|
|
FROM x'1, 1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset1, 1
|
|
2, 2,TEST2,321,31.2,1,2014-07-15T01:18:46Z,stringset1, 1
|
|
3, 1,TEST,-123,1.12,0,2013-07-15T01:18:46Z,stringset2, 2'
|
|
with
|
|
BATCHSIZE 10000
|
|
format 'CSV'
|
|
input 'STREAM';`,
|
|
),
|
|
ExpErr: "an expression of type 'id' cannot be assigned to type 'string'",
|
|
Compare: CompareExactOrdered,
|
|
},
|
|
{
|
|
name: "leftjoin",
|
|
SQLs: sqls(
|
|
"select time_col from bulktest where _id = 'TEST2';",
|
|
),
|
|
ExpHdrs: hdrs(
|
|
hdr("time_col", fldTypeTimestamp),
|
|
),
|
|
ExpRows: rows(
|
|
row(timestampFromString("2014-07-15T01:18:46Z")),
|
|
),
|
|
Compare: CompareExactOrdered,
|
|
},
|
|
},
|
|
}
|