meta: Add a GetDBMeta function to meta.

pkg/meta/meta.go

@@ -1022,6 +1022,51 @@ func (m *Meta) ListTables(dbID int64) ([]*model.TableInfo, error) {
 	return tables, nil
 }
 
+// ListTablesByFilter return all tables that does not filtered by filter in a database.
+// Note(dongmen): This method is used by TiCDC to reduce the time of changefeed initialization.
+// Ref: https://github.com/pingcap/tiflow/issues/11109
+func (m *Meta) ListTablesByFilter(
+	dbID int64,
+	filter func(info *model.TableNameInfo) bool) ([]*model.TableInfo, error) {
+	dbKey := m.dbKey(dbID)
+	if err := m.checkDBExists(dbKey); err != nil {
+		return nil, errors.Trace(err)
+	}
+
+	res, err := m.txn.HGetAll(dbKey)
+	if err != nil {
+		return nil, errors.Trace(err)
+	}
+
+	tables := make([]*model.TableInfo, 0, len(res)/2)
+	for _, r := range res {
+		// only handle table meta
+		tableKey := string(r.Field)
+		if !strings.HasPrefix(tableKey, mTablePrefix) {
+			continue
+		}
+		tbName := &model.TableNameInfo{}
+		err = json.Unmarshal(r.Value, tbName)
+		if err != nil {
+			return nil, errors.Trace(err)
+		}
+		if filter(tbName) {
+			continue
+		}
+
+		tbInfo := &model.TableInfo{}
+		err = json.Unmarshal(r.Value, tbInfo)
+		if err != nil {
+			return nil, errors.Trace(err)
+		}
+		tbInfo.DBID = dbID
+
+		tables = append(tables, tbInfo)
+	}
+
+	return tables, nil
+}
+
 // ListSimpleTables shows all simple tables in database.
 func (m *Meta) ListSimpleTables(dbID int64) ([]*model.TableNameInfo, error) {
 	dbKey := m.dbKey(dbID)

pkg/meta/meta_test.go

@@ -293,6 +293,16 @@ func TestMeta(t *testing.T) {
 		})
 		require.NoError(t, err)
 	}
+
+	// Test ListTableByFilter
+	filter := func(tableName *model.TableNameInfo) bool {
+		return tableName.Name != tblName.Name
+	}
+	filteredTables, err := m.ListTablesByFilter(1, filter)
+	require.NoError(t, err)
+	require.Len(t, filteredTables, 1)
+	require.Equal(t, tblName.Name, filteredTables[0].Name)
+
 	// Generate an auto id.
 	n, err = m.GetAutoIDAccessors(1, 2).RowID().Inc(10)
 	require.NoError(t, err)