Function TestStartCredentialRefresh_StopsCleanly

server/server_test.go:414–443

(t *testing.T)

		t.Fatalf("expected two exec attempts, got %d", calls)
	}
}

func TestConfigureDuckLakeMetadataPoolRunsExpectedStatement(t *testing.T) {
	execer := &mockDuckLakeExecer{}
	configureDuckLakeMetadataPool(execer)

	calls, queries := execer.calls()
	if calls != 1 {
		t.Fatalf("expected one pool-config exec, got %d", calls)
	}
	if len(queries) != 1 || !strings.Contains(queries[0], "postgres_configure_pool") {
		t.Fatalf("expected postgres_configure_pool statement, got %v", queries)
	}
}

func TestDuckLakeMetadataIndexesNamesMatchStatements(t *testing.T) {
	if len(duckLakeMetadataIndexes) == 0 {
		t.Fatalf("duckLakeMetadataIndexes must not be empty")
	}
	seen := make(map[string]struct{}, len(duckLakeMetadataIndexes))
	for _, ix := range duckLakeMetadataIndexes {
		if ix.name == "" {
			t.Errorf("index has empty name: %+v", ix)
		}
		if !strings.Contains(ix.stmt, ix.name) {
			t.Errorf("index %q statement does not reference its own name: %q", ix.name, ix.stmt)
		}
		if !strings.HasPrefix(ix.stmt, "CREATE INDEX IF NOT EXISTS ") {
			t.Errorf("index %q statement must use CREATE INDEX IF NOT EXISTS: %q", ix.name, ix.stmt)
		}
		if _, dup := seen[ix.name]; dup {
			t.Errorf("duplicate index name %q", ix.name)
		}