ExtractorOracle is the main schema extract flow manager.
| 42 | |
| 43 | // ExtractorOracle is the main schema extract flow manager. |
| 44 | type ExtractorOracle struct { |
| 45 | ctx context.Context |
| 46 | execCtx *common.ExecContext |
| 47 | logger g.LoggerType |
| 48 | subject string |
| 49 | mysqlContext *common.MySQLDriverConfig |
| 50 | |
| 51 | systemVariables map[string]string |
| 52 | sqlMode string |
| 53 | lowerCaseTableNames mysqlconfig.LowerCaseTableNamesValue |
| 54 | MySQLVersion string |
| 55 | TotalTransferredBytes int |
| 56 | // Original comment: TotalRowsCopied returns the accurate number of rows being copied (affected) |
| 57 | // This is not exactly the same as the rows being iterated via chunks, but potentially close enough. |
| 58 | // TODO What is the difference between mysqlContext.RowsEstimate ? |
| 59 | TotalRowsCopied int64 |
| 60 | natsAddr string |
| 61 | |
| 62 | mysqlVersionDigit int |
| 63 | oracleDB *config.OracleDB |
| 64 | db *gosql.DB |
| 65 | singletonDB *gosql.DB |
| 66 | //dumpers []*mysql.dumper |
| 67 | // db.tb exists when creating the job, for full-copy. |
| 68 | // vs e.mysqlContext.ReplicateDoDb: all user assigned db.tb |
| 69 | replicateDoDb []*common.DataSource |
| 70 | dataChannel chan *common.EntryContext |
| 71 | inspector *mysql.Inspector |
| 72 | binlogReader *binlog.BinlogReader |
| 73 | LogMinerStream *LogMinerStream |
| 74 | fullCopyCoordinates *common.OracleCoordinates |
| 75 | //rowCopyComplete chan bool |
| 76 | rowCopyCompleteFlag int64 |
| 77 | tableCount int |
| 78 | |
| 79 | sendByTimeoutCounter int |
| 80 | sendBySizeFullCounter int |
| 81 | |
| 82 | natsConn *gonats.Conn |
| 83 | waitCh chan *drivers.ExitResult |
| 84 | |
| 85 | shutdown bool |
| 86 | shutdownCh chan struct{} |
| 87 | shutdownLock sync.Mutex |
| 88 | |
| 89 | testStub1Delay int64 |
| 90 | |
| 91 | context *sqle.Context |
| 92 | |
| 93 | // This must be `<-` after `getSchemaTablesAndMeta()`. |
| 94 | gotCoordinateCh chan struct{} |
| 95 | streamerReadyCh chan error |
| 96 | fullCopyDone chan struct{} |
| 97 | storeManager *common.StoreManager |
| 98 | |
| 99 | timestampCtx *TimestampContext |
| 100 | |
| 101 | memory1 *int64 |
nothing calls this directly
no outgoing calls
no test coverage detected