()
| 1120 | } |
| 1121 | |
| 1122 | func (e *Extractor) sendSysVarAndSqlMode() error { |
| 1123 | // Generate the DDL statements that set the charset-related system variables ... |
| 1124 | if err := e.readMySqlCharsetSystemVariables(); err != nil { |
| 1125 | return err |
| 1126 | } |
| 1127 | e.logger.Debug("system variables", "value", e.systemVariables) |
| 1128 | if err := e.selectSqlMode(); err != nil { |
| 1129 | return err |
| 1130 | } |
| 1131 | setSqlMode := fmt.Sprintf("SET @@session.sql_mode = '%s'", e.sqlMode) |
| 1132 | |
| 1133 | var outSystemVariables [][2]string |
| 1134 | for k, v := range e.systemVariables { |
| 1135 | outSystemVariables = append(outSystemVariables, [2]string{k, v}) |
| 1136 | } |
| 1137 | entry := &common.DumpEntry{ |
| 1138 | SystemVariables: outSystemVariables, |
| 1139 | SqlMode: setSqlMode, |
| 1140 | } |
| 1141 | if err := e.encodeAndSendDumpEntry(entry); err != nil { |
| 1142 | e.onError(common.TaskStateDead, err) |
| 1143 | } |
| 1144 | |
| 1145 | return nil |
| 1146 | } |
| 1147 | |
| 1148 | //Perform the snapshot using the same logic as the "mysqldump" utility. |
| 1149 | func (e *Extractor) mysqlDump() (retErr error) { |
no test coverage detected