(ctx context.Context, stmts []string, _ db.ExecuteOptions)
| 185 | } |
| 186 | |
| 187 | func (d *Driver) executeDDL(ctx context.Context, stmts []string, _ db.ExecuteOptions) (int64, error) { |
| 188 | op, err := d.dbClient.UpdateDatabaseDdl(ctx, &databasepb.UpdateDatabaseDdlRequest{ |
| 189 | Database: getDSN(d.config.DataSource.Host, d.databaseName), |
| 190 | Statements: stmts, |
| 191 | }) |
| 192 | if err != nil { |
| 193 | return 0, err |
| 194 | } |
| 195 | return 0, op.Wait(ctx) |
| 196 | } |
| 197 | |
| 198 | func (d *Driver) executeInTransactionMode(ctx context.Context, stmts []string, opts db.ExecuteOptions) (int64, error) { |
| 199 | var rowCount int64 |
no test coverage detected