database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](binlog) Add dbName && tableName in CreateTableRecord (#26901)

Browse Source 
Signed-off-by: Jack Drogon <jack.xsuperman@gmail.com>
This commit is contained in:
Jack Drogon
2023-11-14 08:29:38 +08:00
committed by GitHub
parent b19abac5e2
commit e7a8022106
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
fe/fe-core/src/main/java/org/apache/doris/binlog/CreateTableRecord.java
View File

@ -37,17 +37,24 @@ public class CreateTableRecord {
private long commitSeq;
@SerializedName(value = "dbId")
private long dbId;
@SerializedName(value = "dbName")
private String dbName;
@SerializedName(value = "tableId")
private long tableId;
@SerializedName(value = "tableName")
private String tableName;
@SerializedName(value = "sql")
private String sql;
public CreateTableRecord(long commitSeq, CreateTableInfo info) {
Table table = info.getTable();
this.commitSeq = commitSeq;
Table table = info.getTable();
this.tableName = table.getName();
this.tableId = table.getId();
String dbName = info.getDbName();
this.dbName = dbName;
Database db = Env.getCurrentInternalCatalog().getDbNullable(dbName);
if (db == null) {