fix: add full_match_handler.go to convert the query.

catalog/initial_data.go

@@ -0,0 +1,32 @@
+package catalog
+
+var InitialDatas = struct {
+	PGNamespace [][]any
+	PGRange     [][]any
+}{
+	PGNamespace: [][]any{
+		{"99", "pg_toast", "10", ""},
+		{"11", "pg_catalog", "10", "{postgres=UC/postgres,=U/postgres}"},
+		{"2200", "public", "6171", "{pg_database_owner,=UC/pg_database_owner,=U/pg_database_owner}"},
+		{"13219", "information_schema", "10", "{postgres=UC/postgres,=U/postgres}"},
+		{"16395", "test_schema", "10", ""},
+	},
+	PGRange: [][]any{
+		{"3904", "23", "4451", "0", "1978", "int4range_canonical", "int4range_subdiff"},
+		{"3906", "1700", "4532", "0", "3125", "-", "numrange_subdiff"},
+		{"3908", "1114", "4533", "0", "3128", "-", "tsrange_subdiff"},
+		{"3910", "1184", "4534", "0", "3127", "-", "tstzrange_subdiff"},
+		{"3912", "1082", "4535", "0", "3122", "daterange_canonical", "daterange_subdiff"},
+		{"3926", "20", "4536", "0", "3124", "int8range_canonical", "int8range_subdiff"},
+	},
+}
+
+var InitialDataFiles = struct {
+	PGClass string
+	PGProc  string
+	PGType  string
+}{
+	PGClass: "pg_class.csv",
+	PGProc:  "pg_proc.csv",
+	PGType:  "pg_type.csv",
+}

catalog/provider.go

@@ -32,6 +32,7 @@ type DatabaseProvider struct {
 	dsn                       string
 	externalProcedureRegistry sql.ExternalStoredProcedureRegistry
 	ready                     bool
+	initialDataDir            string
 }
 
 var _ sql.DatabaseProvider = (*DatabaseProvider)(nil)
@@ -41,20 +42,21 @@ var _ configuration.DataDirProvider = (*DatabaseProvider)(nil)
 
 const readOnlySuffix = "?access_mode=read_only"
 
-func NewInMemoryDBProvider() *DatabaseProvider {
-	prov, err := NewDBProvider("", ".", "")
+func NewInMemoryDBProvider(initialDataDir string) *DatabaseProvider {
+	prov, err := NewDBProvider("", ".", "", initialDataDir)
 	if err != nil {
 		panic(err)
 	}
 	return prov
 }
 
-func NewDBProvider(defaultTimeZone, dataDir, defaultDB string) (prov *DatabaseProvider, err error) {
+func NewDBProvider(defaultTimeZone, dataDir, defaultDB, initialDataDir string) (prov *DatabaseProvider, err error) {
 	prov = &DatabaseProvider{
 		mu:                        &sync.RWMutex{},
 		defaultTimeZone:           defaultTimeZone,
 		externalProcedureRegistry: sql.NewExternalStoredProcedureRegistry(), // This has no effect, just to satisfy the upper layer interface
 		dataDir:                   dataDir,
+		initialDataDir:            initialDataDir,
 	}
 
 	shouldInit := true
@@ -143,6 +145,21 @@ func (prov *DatabaseProvider) initCatalog() error {
 				return fmt.Errorf("failed to insert initial data into internal table %q: %w", t.Name, err)
 			}
 		}
+
+		if t.InitialDataFile != "" {
+			var count int
+			if err := prov.storage.QueryRow(t.CountAllStmt()).Scan(&count); err != nil {
+				return fmt.Errorf("failed to count rows in internal table %q: %w", t.Name, err)
+			}
+			if count == 0 {
+				if _, err := prov.storage.ExecContext(
+					context.Background(),
+					fmt.Sprintf("COPY %s FROM '%s' (FORMAT CSV, HEADER)", t.QualifiedName(), prov.initialDataDir+t.InitialDataFile),
+				); err != nil {
+					return fmt.Errorf("failed to insert initial data from file into internal table %q: %w", t.Name, err)
+				}
+			}
+		}
 	}
 
 	if _, err := prov.pool.ExecContext(context.Background(), "PRAGMA enable_checkpoint_on_shutdown"); err != nil {

compatibility/pg/csharp/PGTest.cs

@@ -14,7 +14,7 @@ public class Tests
 
         public void Connect(string ip, int port, string user, string password)
         {
-            string connectionString = $"Host={ip};Port={port};Username={user};Password={password};Database=postgres;";
+            string connectionString = $"Host={ip};Port={port};Username={user};Password={password};Database=postgres;Timeout=300;CommandTimeout=600;";
             try
             {
                 conn = new NpgsqlConnection(connectionString);

compatibility/pg/test.bats

@@ -43,11 +43,11 @@ start_process() {
 
 # Failed because of the following error:
 # > Catalog Error: Table with name pg_range does not exist!
-# @test "pg-csharp" {
-#     set_custom_teardown "sudo pkill -f dotnet"
-#     start_process dotnet build $BATS_TEST_DIRNAME/csharp/PGTest.csproj -o $BATS_TEST_DIRNAME/csharp/bin
-#     start_process dotnet $BATS_TEST_DIRNAME/csharp/bin/PGTest.dll 127.0.0.1 5432 postgres "" $BATS_TEST_DIRNAME/test.data
-# }
+@test "pg-csharp" {
+    set_custom_teardown "sudo pkill -f dotnet"
+    start_process dotnet build $BATS_TEST_DIRNAME/csharp/PGTest.csproj -o $BATS_TEST_DIRNAME/csharp/bin
+    start_process dotnet $BATS_TEST_DIRNAME/csharp/bin/PGTest.dll 127.0.0.1 5432 postgres "" $BATS_TEST_DIRNAME/test.data
+}
 
 @test "pg-go" {
     start_process go build -o $BATS_TEST_DIRNAME/go/pg $BATS_TEST_DIRNAME/go/pg.go

docker/Dockerfile

@@ -96,6 +96,7 @@ COPY --from=builder /myduckserver /usr/local/bin/myduckserver
 COPY --chown=admin:admin --chmod=755 docker/*.sh .
 COPY --chown=admin:admin --chmod=755 devtools/replica-setup-mysql ./replica-setup-mysql
 COPY --chown=admin:admin --chmod=755 devtools/replica-setup-postgres ./replica-setup-postgres
+COPY --chown=admin:admin --chmod=755 initialdata ./initialdata
 
 # Initialize DuckDB
 RUN myduckserver --init

flightsqltest/driver_test.go

@@ -46,9 +46,9 @@ import (
 	"github.com/apache/arrow-go/v18/arrow/memory"
 )
 
+const defaultDbName = "mysql"
 const defaultTableName = "drivertest"
 const dataDirectory = "."
-const dbFileName = "mysql.db"
 
 var defaultStatements = map[string]string{
 	"create table": `
@@ -92,7 +92,7 @@ func (s *SqlTestSuite) SetupSuite() {
 	}
 
 	s.createServer = func() (flight.Server, string, error) {
-		provider, err := catalog.NewDBProvider(dataDirectory, dbFileName)
+		provider, err := catalog.NewDBProvider("", dataDirectory, defaultDbName, "../initialdata/")
 		if err != nil {
 			return nil, "", err
 		}

harness/duck_harness.go

@@ -401,7 +401,7 @@ func (m *DuckHarness) getProvider() sql.DatabaseProvider {
 }
 
 func (m *DuckHarness) NewDatabaseProvider() sql.MutableDatabaseProvider {
-	return catalog.NewInMemoryDBProvider()
+	return catalog.NewInMemoryDBProvider("./initialdata/")
 }
 
 func (m *DuckHarness) Provider() *catalog.DatabaseProvider {