Function TestJDBCVersionQuery

tests/integration/jdbc_test.go:33–93

TestJDBCVersionQuery tests SELECT version() via extended query protocol, which is the pattern JDBC/Metabase uses on connection and that hangs sporadically.

(t *testing.T)

// TestJDBCVersionQuery tests SELECT version() via extended query protocol,
// which is the pattern JDBC/Metabase uses on connection and that hangs sporadically.
func TestJDBCVersionQuery(t *testing.T) {
	ctx := context.Background()

	t.Run("simple_version", func(t *testing.T) {
		conn := pgxConnect(t)
		defer func() { _ = conn.Close(ctx) }()

		var ver string
		err := conn.QueryRow(ctx, "SELECT version()").Scan(&ver)
		if err != nil {
			t.Fatalf("SELECT version() failed: %v", err)
		}
		if ver == "" {
			t.Error("version() returned empty string")
		}
		t.Logf("version() = %s", ver)
	})

	t.Run("version_with_timeout", func(t *testing.T) {
		conn := pgxConnect(t)
		defer func() { _ = conn.Close(ctx) }()

		tctx, cancel := context.WithTimeout(ctx, 5*time.Second)
		defer cancel()

		var ver string
		err := conn.QueryRow(tctx, "SELECT version()").Scan(&ver)
		if err != nil {
			t.Fatalf("SELECT version() timed out or failed: %v", err)
		}
	})

	t.Run("repeated_version_same_connection", func(t *testing.T) {
		conn := pgxConnect(t)
		defer func() { _ = conn.Close(ctx) }()

		for i := 0; i < 50; i++ {
			tctx, cancel := context.WithTimeout(ctx, 5*time.Second)
			var ver string
			err := conn.QueryRow(tctx, "SELECT version()").Scan(&ver)
			cancel()
			if err != nil {
				t.Fatalf("Iteration %d: SELECT version() failed: %v", i, err)
			}
		}
	})

	t.Run("repeated_version_new_connections", func(t *testing.T) {
		for i := 0; i < 20; i++ {
			conn := pgxConnect(t)
			tctx, cancel := context.WithTimeout(ctx, 5*time.Second)
			var ver string
			err := conn.QueryRow(tctx, "SELECT version()").Scan(&ver)
			cancel()
			_ = conn.Close(ctx)
			if err != nil {
				t.Fatalf("Connection %d: SELECT version() failed: %v", i, err)
			}