File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -77,10 +77,10 @@ func TestFromProtoGenerateCSVCompatibility(t *testing.T) {
7777 // Check for schema creation
7878 assert .Contains (t , fullSQL , `CREATE SCHEMA IF NOT EXISTS "test_schema"` )
7979
80- // Check for system tables
81- assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"." _sink_info_" ` )
82- assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"." _cursor_" ` )
83- assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"." _blocks_" ` )
80+ // Check for system tables (match dialect static SQL, table names unquoted)
81+ assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"._sink_info_` )
82+ assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"._cursor_` )
83+ assert .Contains (t , fullSQL , `CREATE TABLE IF NOT EXISTS "test_schema"._blocks_` )
8484
8585 // Check for user table with system columns
8686 assert .Contains (t , fullSQL , `_block_number_ INTEGER NOT NULL` )
You can’t perform that action at this time.
0 commit comments