Method Execute

backend/plugin/db/hive/hive.go:147–179

Transaction statements [BEGIN, COMMIT, ROLLBACK] are not supported in Hive 4.0 temporarily. Even in Hive's bucketed transaction table, all the statements are committed automatically by the Hive server.

(ctx context.Context, statementsStr string, _ db.ExecuteOptions)

// Even in Hive's bucketed transaction table, all the statements are committed automatically by
// the Hive server.
func (d *Driver) Execute(ctx context.Context, statementsStr string, _ db.ExecuteOptions) (int64, error) {
	// Hive has limited transaction support:
	// - Only ACID tables support transactions, and even then it's limited
	// - Transaction statements (BEGIN, COMMIT, ROLLBACK) are not supported in Hive 4.0
	// - All statements are auto-committed by the Hive server
	// Due to these limitations, we execute statements individually regardless of transaction mode
	// but we still parse and respect the transaction mode directive for consistency

	if d.db == nil {
		return 0, errors.New("connection not initialized")
	}

	statements, err := base.SplitMultiSQL(storepb.Engine_HIVE, statementsStr)
	if err != nil {
		return 0, errors.Wrapf(err, "failed to split statements")
	}

	var totalAffected int64
	for _, statement := range statements {
		query := strings.TrimRight(statement.Text, ";")

		result, err := d.db.ExecContext(ctx, query)
		if err != nil {
			return totalAffected, errors.Wrapf(err, "failed to execute statement: %s", query)
		}

		// Hive may not always return accurate row counts
		affected, _ := result.RowsAffected()
		totalAffected += affected
	}

	return totalAffected, nil
}

func (d *Driver) QueryConn(ctx context.Context, _ *sql.Conn, statement string, queryCtx db.QueryContext) ([]*v1pb.QueryResult, error) {
	if d.db == nil {