mysql

func BuildPkColumns ¶

func BuildPkColumns(table *schema_store.Table, tableConfig *config.TableConfig) []schema_store.Column

func GenPrimaryKeys ¶

func GenPrimaryKeys(pkColumns []schema_store.Column, rowData map[string]interface{}) (map[string]interface{}, error)

func MySQLDataEquals ¶

func MySQLDataEquals(a interface{}, b interface{}) bool

func NormalizeSQLType ¶

func NormalizeSQLType(a interface{}) interface{}

func SQLDataPtrs2Val ¶

func SQLDataPtrs2Val(dataPtrs []interface{}, columnTypes []*sql.ColumnType) map[string]interface{}

+ scanTypeFloat32 = reflect.TypeOf(float32(0)) + scanTypeFloat64 = reflect.TypeOf(float64(0)) + scanTypeInt8 = reflect.TypeOf(int8(0)) + scanTypeInt16 = reflect.TypeOf(int16(0)) + scanTypeInt32 = reflect.TypeOf(int32(0)) + scanTypeInt64 = reflect.TypeOf(int64(0)) + scanTypeNullFloat = reflect.TypeOf(sql.NullFloat64{}) + scanTypeNullInt = reflect.TypeOf(sql.NullInt64{}) + scanTypeNullTime = reflect.TypeOf(NullTime{}) + scanTypeUint8 = reflect.TypeOf(uint8(0)) + scanTypeUint16 = reflect.TypeOf(uint16(0)) + scanTypeUint32 = reflect.TypeOf(uint32(0)) + scanTypeUint64 = reflect.TypeOf(uint64(0)) + scanTypeRawBytes = reflect.TypeOf(sql.RawBytes{}) + scanTypeUnknown = reflect.TypeOf(new(interface{}))