feat: support transaction options in BEGIN statements (#550)

* feat: parse SET TRANSACTION statements

Parse SET TRANSACTION statements and translate these to SET LOCAL statements.
SET TRANSACTION may only be executed in a transaction block, and can only be
used for a specific, limited set of connection properties. The syntax is
specified by the SQL standard and PostgreSQL.

See also https://www.postgresql.org/docs/current/sql-set-transaction.html

This change only adds partial support. The following features will be added
in future changes:
1. SET TRANSACTION READ {WRITE | ONLY} is not picked up by the driver, as
   the type of transaction is set directly when BeginTx is called. A
   refactor of this transaction handling is needed to be able to pick up
   SET TRANSACTION READ ONLY / SET TRANSACTION READ WRITE statements that
   are executed after BeginTx has been called.
2. PostgreSQL allows multiple transaction modes to be set in a single
   SET TRANSACTION statement. E.g. the following is allowed:
   SET TRANSACTION READ WRITE, ISOLATION LEVEL SERIALIZABLE
   The current implementation only supports one transaction mode per
   SET statement.

* feat: support multiple transaction options in one statement

* feat: support transaction options in BEGIN statements

Adds support for including transaction options in BEGIN statements, like:

```sql
BEGIN READ ONLY;
BEGIN READ WRITE;
BEGIN TRANSACTION ISOLATION LEVEL REPEATABLE READ;
BEGIN READ WRITE, ISOLATION LEVEL SERIALIZABLE;
```

* chore: re-trigger checks

Author: olavloite

parser/statements.go

@@ -230,77 +230,92 @@ func (s *ParsedSetStatement) parseSetTransaction(sp *simpleParser, query string)
 	s.IsLocal = true
 	s.IsTransaction = true
 
+	var err error
+	s.Identifiers, s.Literals, err = parseTransactionOptions(sp)
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func parseTransactionOptions(sp *simpleParser) ([]Identifier, []Literal, error) {
+	identifiers := make([]Identifier, 0, 2)
+	literals := make([]Literal, 0, 2)
+	var err error
 	for {
 		if sp.peekKeyword("ISOLATION") {
-			if err := s.parseSetTransactionIsolationLevel(sp, query); err != nil {
-				return err
+			identifiers, literals, err = parseTransactionIsolationLevel(sp, identifiers, literals)
+			if err != nil {
+				return nil, nil, err
 			}
 		} else if sp.peekKeyword("READ") {
-			if err := s.parseSetTransactionMode(sp, query); err != nil {
-				return err
+			identifiers, literals, err = parseTransactionMode(sp, identifiers, literals)
+			if err != nil {
+				return nil, nil, err
 			}
 		} else if sp.statementParser.Dialect == databasepb.DatabaseDialect_POSTGRESQL && (sp.peekKeyword("DEFERRABLE") || sp.peekKeyword("NOT")) {
 			// https://www.postgresql.org/docs/current/sql-set-transaction.html
-			if err := s.parseSetTransactionDeferrable(sp, query); err != nil {
-				return err
+			identifiers, literals, err = parseTransactionDeferrable(sp, identifiers, literals)
+			if err != nil {
+				return nil, nil, err
 			}
 		} else {
-			return status.Error(codes.InvalidArgument, "invalid TRANSACTION option, expected one of ISOLATION LEVEL, READ WRITE, or READ ONLY")
+			return nil, nil, status.Error(codes.InvalidArgument, "invalid TRANSACTION option, expected one of ISOLATION LEVEL, READ WRITE, or READ ONLY")
 		}
 		if !sp.hasMoreTokens() {
-			return nil
+			return identifiers, literals, nil
 		}
 		// Eat and ignore any commas separating the various options.
 		sp.eatToken(',')
 	}
 }
 
-func (s *ParsedSetStatement) parseSetTransactionIsolationLevel(sp *simpleParser, query string) error {
+func parseTransactionIsolationLevel(sp *simpleParser, identifiers []Identifier, literals []Literal) ([]Identifier, []Literal, error) {
 	if !sp.eatKeywords([]string{"ISOLATION", "LEVEL"}) {
-		return status.Errorf(codes.InvalidArgument, "syntax error: expected ISOLATION LEVEL")
+		return nil, nil, status.Errorf(codes.InvalidArgument, "syntax error: expected ISOLATION LEVEL")
 	}
 	var value Literal
 	if sp.eatKeyword("SERIALIZABLE") {
 		value = Literal{Value: "serializable"}
 	} else if sp.eatKeywords([]string{"REPEATABLE", "READ"}) {
 		value = Literal{Value: "repeatable_read"}
 	} else {
-		return status.Errorf(codes.InvalidArgument, "syntax error: expected SERIALIZABLE OR REPETABLE READ")
+		return nil, nil, status.Errorf(codes.InvalidArgument, "syntax error: expected SERIALIZABLE OR REPETABLE READ")
 	}
 
-	s.Identifiers = append(s.Identifiers, Identifier{Parts: []string{"isolation_level"}})
-	s.Literals = append(s.Literals, value)
-	return nil
+	identifiers = append(identifiers, Identifier{Parts: []string{"isolation_level"}})
+	literals = append(literals, value)
+	return identifiers, literals, nil
 }
 
-func (s *ParsedSetStatement) parseSetTransactionMode(sp *simpleParser, query string) error {
+func parseTransactionMode(sp *simpleParser, identifiers []Identifier, literals []Literal) ([]Identifier, []Literal, error) {
 	readOnly := false
 	if sp.eatKeywords([]string{"READ", "ONLY"}) {
 		readOnly = true
 	} else if sp.eatKeywords([]string{"READ", "WRITE"}) {
 		readOnly = false
 	} else {
-		return status.Errorf(codes.InvalidArgument, "syntax error: expected READ ONLY or READ WRITE")
+		return nil, nil, status.Errorf(codes.InvalidArgument, "syntax error: expected READ ONLY or READ WRITE")
 	}
 
-	s.Identifiers = append(s.Identifiers, Identifier{Parts: []string{"transaction_read_only"}})
-	s.Literals = append(s.Literals, Literal{Value: fmt.Sprintf("%v", readOnly)})
-	return nil
+	identifiers = append(identifiers, Identifier{Parts: []string{"transaction_read_only"}})
+	literals = append(literals, Literal{Value: fmt.Sprintf("%v", readOnly)})
+	return identifiers, literals, nil
 }
 
-func (s *ParsedSetStatement) parseSetTransactionDeferrable(sp *simpleParser, query string) error {
+func parseTransactionDeferrable(sp *simpleParser, identifiers []Identifier, literals []Literal) ([]Identifier, []Literal, error) {
 	deferrable := false
 	if sp.eatKeywords([]string{"NOT", "DEFERRABLE"}) {
 		deferrable = false
 	} else if sp.eatKeyword("DEFERRABLE") {
 		deferrable = true
 	} else {
-		return status.Errorf(codes.InvalidArgument, "syntax error: expected [NOT] DEFERRABLE")
+		return nil, nil, status.Errorf(codes.InvalidArgument, "syntax error: expected [NOT] DEFERRABLE")
 	}
 
-	s.Identifiers = append(s.Identifiers, Identifier{Parts: []string{"transaction_deferrable"}})
-	s.Literals = append(s.Literals, Literal{Value: fmt.Sprintf("%v", deferrable)})
-	return nil
+	identifiers = append(identifiers, Identifier{Parts: []string{"transaction_deferrable"}})
+	literals = append(literals, Literal{Value: fmt.Sprintf("%v", deferrable)})
+	return identifiers, literals, nil
 }
 
 // ParsedResetStatement is a statement of the form
@@ -496,6 +511,12 @@ func (s *ParsedAbortBatchStatement) parse(parser *StatementParser, query string)
 
 type ParsedBeginStatement struct {
 	query string
+	// Identifiers contains the transaction properties that were included in the BEGIN statement. E.g. the statement
+	// BEGIN TRANSACTION READ ONLY contains the transaction property 'transaction_read_only'.
+	Identifiers []Identifier
+	// Literals contains the transaction property values that were included in the BEGIN statement. E.g. the statement
+	// BEGIN TRANSACTION READ ONLY contains the value 'true' for the property 'transaction_read_only'.
+	Literals []Literal
 }
 
 func (s *ParsedBeginStatement) Name() string {
@@ -508,7 +529,7 @@ func (s *ParsedBeginStatement) Query() string {
 
 func (s *ParsedBeginStatement) parse(parser *StatementParser, query string) error {
 	// Parse a statement of the form
-	// GoogleSQL: BEGIN [TRANSACTION]
+	// GoogleSQL: BEGIN [TRANSACTION] [READ WRITE | READ ONLY | ISOLATION LEVEL {SERIALIZABLE | READ COMMITTED}]
 	// PostgreSQL: {START | BEGIN} [{TRANSACTION | WORK}] (https://www.postgresql.org/docs/current/sql-begin.html)
 	// TODO: Support transaction modes in the BEGIN / START statement.
 	sp := &simpleParser{sql: []byte(query), statementParser: parser}
@@ -531,8 +552,13 @@ func (s *ParsedBeginStatement) parse(parser *StatementParser, query string) erro
 	}
 
 	if sp.hasMoreTokens() {
-		return status.Errorf(codes.InvalidArgument, "unexpected tokens at position %d in %q", sp.pos, sp.sql)
+		var err error
+		s.Identifiers, s.Literals, err = parseTransactionOptions(sp)
+		if err != nil {
+			return err
+		}
 	}
+
 	s.query = query
 	return nil
 }

parser/statements_test.go

@@ -431,6 +431,38 @@ func TestParseBeginStatementGoogleSQL(t *testing.T) {
 			input:   "begin transaction foo",
 			wantErr: true,
 		},
+		{
+			input: "begin read only",
+			want: ParsedBeginStatement{
+				query:       "begin read only",
+				Identifiers: []Identifier{{Parts: []string{"transaction_read_only"}}},
+				Literals:    []Literal{{Value: "true"}},
+			},
+		},
+		{
+			input: "begin read write",
+			want: ParsedBeginStatement{
+				query:       "begin read write",
+				Identifiers: []Identifier{{Parts: []string{"transaction_read_only"}}},
+				Literals:    []Literal{{Value: "false"}},
+			},
+		},
+		{
+			input: "begin transaction isolation level serializable",
+			want: ParsedBeginStatement{
+				query:       "begin transaction isolation level serializable",
+				Identifiers: []Identifier{{Parts: []string{"isolation_level"}}},
+				Literals:    []Literal{{Value: "serializable"}},
+			},
+		},
+		{
+			input: "begin transaction isolation level repeatable read, read write",
+			want: ParsedBeginStatement{
+				query:       "begin transaction isolation level repeatable read, read write",
+				Identifiers: []Identifier{{Parts: []string{"isolation_level"}}, {Parts: []string{"transaction_read_only"}}},
+				Literals:    []Literal{{Value: "repeatable_read"}, {Value: "false"}},
+			},
+		},
 	}
 	parser, err := NewStatementParser(databasepb.DatabaseDialect_GOOGLE_STANDARD_SQL, 1000)
 	if err != nil {
@@ -454,7 +486,7 @@ func TestParseBeginStatementGoogleSQL(t *testing.T) {
 					t.Fatalf("parseStatement(%q) should have returned a *parsedBeginStatement", test.input)
 				}
 				if !reflect.DeepEqual(*showStmt, test.want) {
-					t.Errorf("parseStatement(%q) = %v, want %v", test.input, *showStmt, test.want)
+					t.Errorf("parseStatement(%q) mismatch\n Got: %v\nWant: %v", test.input, *showStmt, test.want)
 				}
 			}
 		})
@@ -506,6 +538,56 @@ func TestParseBeginStatementPostgreSQL(t *testing.T) {
 				query: "start work",
 			},
 		},
+		{
+			input: "start work read only",
+			want: ParsedBeginStatement{
+				query:       "start work read only",
+				Identifiers: []Identifier{{Parts: []string{"transaction_read_only"}}},
+				Literals:    []Literal{{Value: "true"}},
+			},
+		},
+		{
+			input: "begin read write",
+			want: ParsedBeginStatement{
+				query:       "begin read write",
+				Identifiers: []Identifier{{Parts: []string{"transaction_read_only"}}},
+				Literals:    []Literal{{Value: "false"}},
+			},
+		},
+		{
+			input: "begin read write, isolation level repeatable read",
+			want: ParsedBeginStatement{
+				query:       "begin read write, isolation level repeatable read",
+				Identifiers: []Identifier{{Parts: []string{"transaction_read_only"}}, {Parts: []string{"isolation_level"}}},
+				Literals:    []Literal{{Value: "false"}, {Value: "repeatable_read"}},
+			},
+		},
+		{
+			// Note that it is possible to set multiple conflicting transaction options in one statement.
+			// This statement for example sets the transaction to both read/write and read-only.
+			// The last option will take precedence, as these options are essentially the same as executing the
+			// following statements sequentially after the BEGIN TRANSACTION statement:
+			// SET TRANSACTION READ WRITE
+			// SET TRANSACTION ISOLATION LEVEL REPEATABLE READ
+			// SET TRANSACTION READ ONLY
+			// SET TRANSACTION DEFERRABLE
+			input: "begin transaction \nread write,\nisolation level repeatable read\nread only\ndeferrable",
+			want: ParsedBeginStatement{
+				query: "begin transaction \nread write,\nisolation level repeatable read\nread only\ndeferrable",
+				Identifiers: []Identifier{
+					{Parts: []string{"transaction_read_only"}},
+					{Parts: []string{"isolation_level"}},
+					{Parts: []string{"transaction_read_only"}},
+					{Parts: []string{"transaction_deferrable"}},
+				},
+				Literals: []Literal{
+					{Value: "false"},
+					{Value: "repeatable_read"},
+					{Value: "true"},
+					{Value: "true"},
+				},
+			},
+		},
 		{
 			input:   "start foo",
 			wantErr: true,
@@ -541,7 +623,7 @@ func TestParseBeginStatementPostgreSQL(t *testing.T) {
 					t.Fatalf("parseStatement(%q) should have returned a *parsedBeginStatement", test.input)
 				}
 				if !reflect.DeepEqual(*showStmt, test.want) {
-					t.Errorf("parseStatement(%q) = %v, want %v", test.input, *showStmt, test.want)
+					t.Errorf("parseStatement(%q) mismatch\n Got: %v\nWant: %v", test.input, *showStmt, test.want)
 				}
 			}
 		})

statements.go

@@ -279,10 +279,19 @@ type executableBeginStatement struct {
 }
 
 func (s *executableBeginStatement) execContext(ctx context.Context, c *conn, opts *ExecOptions) (driver.Result, error) {
+	if len(s.stmt.Identifiers) != len(s.stmt.Literals) {
+		return nil, status.Errorf(codes.InvalidArgument, "statement contains %d identifiers, but %d values given", len(s.stmt.Identifiers), len(s.stmt.Literals))
+	}
 	_, err := c.BeginTx(ctx, driver.TxOptions{})
 	if err != nil {
 		return nil, err
 	}
+	for index := range s.stmt.Identifiers {
+		if err := c.setConnectionVariable(s.stmt.Identifiers[index], s.stmt.Literals[index].Value /*IsLocal=*/, true /*IsTransaction=*/, true); err != nil {
+			return nil, err
+		}
+	}
+
 	return driver.ResultNoRows, nil
 }