MCPcopy Index your code
hub / github.com/bytebase/bytebase / executeInAutoCommitMode

Method executeInAutoCommitMode

backend/plugin/db/spanner/spanner.go:230–242  ·  view source on GitHub ↗
(ctx context.Context, stmts []string, _ db.ExecuteOptions)

Source from the content-addressed store, hash-verified

228}
229
230func (d *Driver) executeInAutoCommitMode(ctx context.Context, stmts []string, _ db.ExecuteOptions) (int64, error) {
231 var rowCount int64
232 // Execute statements individually in auto-commit mode
233 for _, stmt := range stmts {
234 spannerStmt := spanner.NewStatement(stmt)
235 count, err := d.client.PartitionedUpdate(ctx, spannerStmt)
236 if err != nil {
237 return rowCount, err
238 }
239 rowCount += count
240 }
241 return rowCount, nil
242}
243
244func (d *Driver) creataDatabase(ctx context.Context, createStatement string, extraStatement []string) error {
245 op, err := d.dbClient.CreateDatabase(ctx, &databasepb.CreateDatabaseRequest{

Callers 1

ExecuteMethod · 0.95

Implementers 15

MockDriverbackend/plugin/advisor/utils_for_tests
Driverbackend/plugin/db/bigquery/bigquery.go
Driverbackend/plugin/db/mongodb/mongodb.go
Driverbackend/plugin/db/trino/trino.go
Driverbackend/plugin/db/redshift/redshift.go
Driverbackend/plugin/db/oracle/oracle.go
Driverbackend/plugin/db/dynamodb/dynamodb.go
Driverbackend/plugin/db/cosmosdb/cosmosdb.go
Driverbackend/plugin/db/spanner/spanner.go
Driverbackend/plugin/db/mssql/mssql.go
Driverbackend/plugin/db/mysql/mysql.go
Driverbackend/plugin/db/pg/pg.go

Calls

no outgoing calls

Tested by

no test coverage detected