瀏覽代碼

添加TODO

yjp 1 年之前
父節點
當前提交
be909c6ac8
共有 2 個文件被更改,包括 5 次插入1 次删除
  1. 3 1
      db_operations/db_operations.go
  2. 2 0
      sdk/sdk.go

+ 3 - 1
db_operations/db_operations.go

@@ -13,9 +13,11 @@ type TransactionDBOperations interface {
 }
 
 type EventDBOperations interface {
-	BaseDBOperations
 	RollbackEvent()
 	CommitEvent()
+	// TODO 需要重新定义创建等方法,传递必要的key
+	EventRows(table string, keys []string, pageSize int, pageNo string)
+	Replay(table string, keys []string)
 }
 
 type BaseDBOperations interface {

+ 2 - 0
sdk/sdk.go

@@ -56,6 +56,8 @@ func (s *SDK) GetDataContainers(name string, pageNo int, pageSize int) ([]client
 		options.namespace, options.dataSource.Name, name, pageNo, pageSize)
 }
 
+// TODO 增加Event版本的Container创建
+
 func (s *SDK) ExecuteRawSql(sql string) ([]map[string]any, error) {
 	if strutils.IsStringEmpty(sql) {
 		return make([]map[string]any, 0), nil