mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-10-08 03:47:51 +00:00
ad5f1d4eaa
Assignment compatibility checking in analyzeBulkInsertStatement is now tested. This isn't checking the values themselves, it's there to make sure the structure is correct for mapping values to columns.
94 lines
2.9 KiB
Go
94 lines
2.9 KiB
Go
package defs
|
|
|
|
// join tests
|
|
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,
|
|
},
|
|
},
|
|
}
|