Function TestProtocolErrors

tests/integration/protocol_test.go:345–388

TestProtocolErrors tests error handling

(t *testing.T)

// TestProtocolErrors tests error handling
func TestProtocolErrors(t *testing.T) {
	t.Run("syntax_error", func(t *testing.T) {
		_, err := testHarness.DuckgresDB.Query("SELEC 1") // typo
		if err == nil {
			t.Error("Expected syntax error")
		}
	})

	t.Run("table_not_found", func(t *testing.T) {
		_, err := testHarness.DuckgresDB.Query("SELECT * FROM nonexistent_table_xyz")
		if err == nil {
			t.Error("Expected table not found error")
		}
	})

	t.Run("column_not_found", func(t *testing.T) {
		_, err := testHarness.DuckgresDB.Query("SELECT nonexistent_column FROM users")
		if err == nil {
			t.Error("Expected column not found error")
		}
	})

	t.Run("type_error", func(t *testing.T) {
		_, err := testHarness.DuckgresDB.Query("SELECT 'not a number'::INTEGER")
		if err == nil {
			t.Error("Expected type error")
		}
	})

	t.Run("error_recovery", func(t *testing.T) {
		// After an error, connection should still be usable
		_, _ = testHarness.DuckgresDB.Query("SELECT * FROM nonexistent") // This should error

		// But this should work
		var val int
		err := testHarness.DuckgresDB.QueryRow("SELECT 1").Scan(&val)
		if err != nil {
			t.Errorf("Query after error failed: %v", err)
		}
		if val != 1 {
			t.Errorf("Expected 1, got %d", val)
		}
	})
}

// TestProtocolDataTypes tests that various data types are correctly transmitted
func TestProtocolDataTypes(t *testing.T) {