|
@@ -62,7 +62,7 @@ func handleCancalUserRelateConsume(msg []byte) error { |
|
|
if masterId != "15763466" { |
|
|
if masterId != "15763466" { |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|
engine := db.DBs["123456"] |
|
|
|
|
|
|
|
|
engine := db.DBs[masterId] |
|
|
// |
|
|
// |
|
|
|
|
|
|
|
|
if canalMsg.Type == md.CanalMsgInsertSqlType { |
|
|
if canalMsg.Type == md.CanalMsgInsertSqlType { |
|
|