105 lines
3.5 KiB
Go
105 lines
3.5 KiB
Go
package jet
|
|
|
|
import (
|
|
"gotest.tools/assert"
|
|
"strconv"
|
|
"testing"
|
|
)
|
|
|
|
var DefaultDialect = NewDialect(DialectParams{ // just for tests
|
|
AliasQuoteChar: '"',
|
|
IdentifierQuoteChar: '"',
|
|
ArgumentPlaceholder: func(ord int) string {
|
|
return "$" + strconv.Itoa(ord)
|
|
},
|
|
})
|
|
|
|
var table1Col1 = IntegerColumn("col1")
|
|
var table1ColInt = IntegerColumn("col_int")
|
|
var table1ColFloat = FloatColumn("col_float")
|
|
var table1Col3 = IntegerColumn("col3")
|
|
var table1ColTime = TimeColumn("col_time")
|
|
var table1ColTimez = TimezColumn("col_timez")
|
|
var table1ColTimestamp = TimestampColumn("col_timestamp")
|
|
var table1ColTimestampz = TimestampzColumn("col_timestampz")
|
|
var table1ColBool = BoolColumn("col_bool")
|
|
var table1ColDate = DateColumn("col_date")
|
|
|
|
var table1 = NewTable("db", "table1", table1Col1, table1ColInt, table1ColFloat, table1Col3, table1ColTime, table1ColTimez, table1ColBool, table1ColDate, table1ColTimestamp, table1ColTimestampz)
|
|
|
|
var table2Col3 = IntegerColumn("col3")
|
|
var table2Col4 = IntegerColumn("col4")
|
|
var table2ColInt = IntegerColumn("col_int")
|
|
var table2ColFloat = FloatColumn("col_float")
|
|
var table2ColStr = StringColumn("col_str")
|
|
var table2ColBool = BoolColumn("col_bool")
|
|
var table2ColTime = TimeColumn("col_time")
|
|
var table2ColTimez = TimezColumn("col_timez")
|
|
var table2ColTimestamp = TimestampColumn("col_timestamp")
|
|
var table2ColTimestampz = TimestampzColumn("col_timestampz")
|
|
var table2ColDate = DateColumn("col_date")
|
|
|
|
var table2 = NewTable("db", "table2", table2Col3, table2Col4, table2ColInt, table2ColFloat, table2ColStr, table2ColBool, table2ColTime, table2ColTimez, table2ColDate, table2ColTimestamp, table2ColTimestampz)
|
|
|
|
var table3Col1 = IntegerColumn("col1")
|
|
var table3ColInt = IntegerColumn("col_int")
|
|
var table3StrCol = StringColumn("col2")
|
|
var table3 = NewTable("db", "table3", table3Col1, table3ColInt, table3StrCol)
|
|
|
|
func assertClauseSerialize(t *testing.T, clause Serializer, query string, args ...interface{}) {
|
|
out := SqlBuilder{Dialect: DefaultDialect}
|
|
err := clause.serialize(SelectStatementType, &out)
|
|
|
|
assert.NilError(t, err)
|
|
|
|
//fmt.Println(out.Buff.String())
|
|
|
|
assert.DeepEqual(t, out.Buff.String(), query)
|
|
assert.DeepEqual(t, out.Args, args)
|
|
}
|
|
|
|
func assertClauseSerializeErr(t *testing.T, clause Serializer, errString string) {
|
|
out := SqlBuilder{Dialect: DefaultDialect}
|
|
err := clause.serialize(SelectStatementType, &out)
|
|
|
|
//fmt.Println(out.buff.String())
|
|
assert.Assert(t, err != nil)
|
|
assert.Error(t, err, errString)
|
|
}
|
|
|
|
func assertClauseDebugSerialize(t *testing.T, clause Serializer, query string, args ...interface{}) {
|
|
out := SqlBuilder{Dialect: DefaultDialect, debug: true}
|
|
err := clause.serialize(SelectStatementType, &out)
|
|
|
|
assert.NilError(t, err)
|
|
|
|
//fmt.Println(out.Buff.String())
|
|
|
|
assert.DeepEqual(t, out.Buff.String(), query)
|
|
assert.DeepEqual(t, out.Args, args)
|
|
}
|
|
|
|
func assertProjectionSerialize(t *testing.T, projection Projection, query string, args ...interface{}) {
|
|
out := SqlBuilder{Dialect: DefaultDialect}
|
|
err := projection.serializeForProjection(SelectStatementType, &out)
|
|
|
|
assert.NilError(t, err)
|
|
|
|
assert.DeepEqual(t, out.Buff.String(), query)
|
|
assert.DeepEqual(t, out.Args, args)
|
|
}
|
|
|
|
func assertStatement(t *testing.T, query Statement, expectedQuery string, expectedArgs ...interface{}) {
|
|
queryStr, args, err := query.Sql()
|
|
assert.NilError(t, err)
|
|
|
|
assert.Equal(t, queryStr, expectedQuery)
|
|
assert.DeepEqual(t, args, expectedArgs)
|
|
}
|
|
|
|
func assertStatementErr(t *testing.T, stmt Statement, errorStr string) {
|
|
_, _, err := stmt.Sql()
|
|
|
|
assert.Assert(t, err != nil)
|
|
assert.Error(t, err, errorStr)
|
|
}
|