testutils

package

v0.1.9 Latest Latest Go to latest Published: Aug 15, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/datazip-inc/olake

Links

Documentation ¶

Index ¶

Variables
func VerifyIcebergSync(t *testing.T, tableName string, datatypeSchema map[string]string, ...)
type IntegrationTest
- func (cfg *IntegrationTest) TestIntegration(t *testing.T)

Constants ¶

This section is empty.

Variables ¶

View Source

var GlobalTypeMapping = map[string]string{

	"tinyint":            "int",
	"smallint":           "int",
	"mediumint":          "int",
	"int":                "int",
	"integer":            "int",
	"unsigned int":       "int",
	"unsigned smallint":  "int",
	"unsigned tinyint":   "int",
	"unsigned mediumint": "int",
	"int2":               "int",
	"int4":               "int",
	"smallserial":        "int",
	"serial":             "int",
	"serial2":            "int",
	"serial4":            "int",

	"bigint":    "bigint",
	"int8":      "bigint",
	"serial8":   "bigint",
	"bigserial": "bigint",
	"year":      "bigint",

	"float":   "float",
	"real":    "float",
	"decimal": "float",
	"numeric": "float",
	"float4":  "float",
	"money":   "float",

	"double":           "double",
	"float8":           "double",
	"double precision": "double",

	"bool":    "boolean",
	"boolean": "boolean",

	"char":              "string",
	"varchar":           "string",
	"tinytext":          "string",
	"text":              "string",
	"mediumtext":        "string",
	"longtext":          "string",
	"character":         "string",
	"character varying": "string",
	"longvarchar":       "string",
	"bpchar":            "string",
	"name":              "string",

	"binary":     "string",
	"varbinary":  "string",
	"tinyblob":   "string",
	"blob":       "string",
	"mediumblob": "string",
	"longblob":   "string",
	"bytea":      "string",

	"json":   "string",
	"jsonb":  "string",
	"xml":    "string",
	"hstore": "string",

	"cidr":     "string",
	"inet":     "string",
	"macaddr":  "string",
	"macaddr8": "string",

	"geometry":           "string",
	"point":              "string",
	"linestring":         "string",
	"polygon":            "string",
	"multipoint":         "string",
	"multilinestring":    "string",
	"multipolygon":       "string",
	"geometrycollection": "string",
	"circle":             "string",
	"path":               "string",
	"box":                "string",
	"line":               "string",
	"lseg":               "string",

	"tsvector": "string",
	"tsquery":  "string",

	"uuid": "string",

	"tsrange":   "string",
	"tstzrange": "string",
	"int4range": "string",
	"numrange":  "string",
	"daterange": "string",

	"array":      "string",
	"ARRAY":      "string",
	"int2vector": "string",

	"enum": "string",
	"set":  "string",

	"date":                        "timestamp",
	"timestamp":                   "timestamp",
	"datetime":                    "timestamp",
	"timestamptz":                 "timestamp",
	"timestamp with time zone":    "timestamp",
	"timestamp without time zone": "timestamp",

	"time":     "string",
	"timez":    "string",
	"interval": "string",

	"pg_lsn":      "string",
	"bit varying": "string",
	"varbit":      "string",
	"bit(n)":      "string",
	"varying(n)":  "string",
}

GlobalTypeToDataType maps database-specific types (Postgres/MySQL) to internal standard types

Functions ¶

func VerifyIcebergSync ¶

func VerifyIcebergSync(t *testing.T, tableName string, datatypeSchema map[string]string, schema map[string]interface{}, opSymbol, driver string)

verifyIcebergSync verifies that data was correctly synchronized to Iceberg

Types ¶

type IntegrationTest ¶

type IntegrationTest struct {
	Driver             string
	ExpectedData       map[string]interface{}
	ExpectedUpdateData map[string]interface{}
	DataTypeSchema     map[string]string
	ExecuteQuery       func(ctx context.Context, t *testing.T, tableName, operation string)
}

func (*IntegrationTest) TestIntegration ¶

func (cfg *IntegrationTest) TestIntegration(t *testing.T)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL