(storageEngine string)
| 337 | } |
| 338 | |
| 339 | func (mctx *MigrationContext) SetConnectionConfig(storageEngine string) error { |
| 340 | var transactionIsolation string |
| 341 | switch storageEngine { |
| 342 | case "rocksdb": |
| 343 | transactionIsolation = "READ-COMMITTED" |
| 344 | default: |
| 345 | transactionIsolation = "REPEATABLE-READ" |
| 346 | } |
| 347 | mctx.InspectorConnectionConfig.TransactionIsolation = transactionIsolation |
| 348 | mctx.ApplierConnectionConfig.TransactionIsolation = transactionIsolation |
| 349 | return nil |
| 350 | } |
| 351 | |
| 352 | func (mctx *MigrationContext) SetConnectionCharset(charset string) { |
| 353 | if charset == "" { |
no outgoing calls