优化日志

sqldef/table_create.go

@@ -33,7 +33,7 @@ func NewTableSyncer(db *sqlx.DB, dbType string) (*TableSyncer, error) {
 
 // CreateAllTables 同步所有注册的表
 // recreate: true - 表存在则删除重建；false - 表不存在则创建
-func (ts *TableSyncer) CreateAllTables(recreate bool) error {
+func (ts *TableSyncer) createAllTables(recreate bool) error {
 	// 确保注册表已初始化
 	globalRegistry.ensureInit()
 
@@ -136,33 +136,31 @@ func (ts *TableSyncer) createTable(table generators.TableDDL) error {
 	return nil
 }
 
-// CreateTables 创建所有不存在的表
-func (ts *TableSyncer) CreateTables() error {
-	return ts.CreateAllTables(false)
-}
-
-// RecreateTables 重建所有表
-func (ts *TableSyncer) RecreateTables() error {
-	return ts.CreateAllTables(true)
-}
-
-// 包级便捷函数
-
 // SyncTables 同步所有表
-func SyncTables(db *sqlx.DB, dbType string, recreate bool) error {
+func syncTables(db *sqlx.DB, dbType string, recreate bool) error {
 	syncer, err := NewTableSyncer(db, dbType)
 	if err != nil {
 		return err
 	}
-	return syncer.CreateAllTables(recreate)
+	return syncer.createAllTables(recreate)
 }
 
+// // CreateTables 创建所有不存在的表
+// func CreateTables(db *sqlx.DB, dbType string) error {
+// 	return syncTables(db, dbType, false)
+// }
+
+// // RecreateTables 重建所有表
+// func RecreateTables(db *sqlx.DB, dbType string) error {
+// 	return syncTables(db, dbType, true)
+// }
+
 // CreateTables 创建所有不存在的表
-func CreateTables(db *sqlx.DB, dbType string) error {
-	return SyncTables(db, dbType, false)
+func (ts *TableSyncer) CreateTables() error {
+	return ts.createAllTables(false)
 }
 
 // RecreateTables 重建所有表
-func RecreateTables(db *sqlx.DB, dbType string) error {
-	return SyncTables(db, dbType, true)
+func (ts *TableSyncer) RecreateTables() error {
+	return ts.createAllTables(true)
 }

sqldef/table_manager.go

@@ -3,6 +3,7 @@ package sqldef
 
 import (
 	"fmt"
+	"log"
 	"sync"
 
 	"git.x2erp.com/qdy/go-db/sqldef/generators"
@@ -85,9 +86,9 @@ func (f *TableManagerFactory) GetInstanceWithExecutor(executor DDLExecutor) *Tab
 	return f.instance
 }
 
-// SyncTables 同步所有注册的表结构（懒加载执行器）
+// createTables 建立所有注册的表结构（懒加载执行器）
 // recreate: true - 如果表存在则删除重建；false - 如果表不存在则创建
-func (tm *TableManager) SyncTables(recreate bool) error {
+func (tm *TableManager) createTables(recreate bool) error {
 	// 确保注册表已初始化
 	globalRegistry.ensureInit()
 
@@ -101,9 +102,9 @@ func (tm *TableManager) SyncTables(recreate bool) error {
 
 	// 按顺序处理所有表
 	for _, table := range tables {
-		err := tm.syncTable(table, recreate)
+		err := tm.createTable(table, recreate)
 		if err != nil {
-			return fmt.Errorf("同步表 %s 失败: %w", table.Name, err)
+			return fmt.Errorf("建立表 %s 失败: %w", table.Name, err)
 		}
 	}
 
@@ -127,8 +128,8 @@ func (tm *TableManager) isExecutorInitialized() bool {
 	return tm.initialized && tm.ddlExecutor != nil
 }
 
-// syncTable 同步单个表
-func (tm *TableManager) syncTable(table generators.TableDDL, recreate bool) error {
+// createTable 建立单个表
+func (tm *TableManager) createTable(table generators.TableDDL, recreate bool) error {
 	// 检查表是否存在
 	exists, err := tm.ddlExecutor.TableExists(table.Name)
 	if err != nil {
@@ -143,19 +144,19 @@ func (tm *TableManager) syncTable(table generators.TableDDL, recreate bool) erro
 			if err := tm.ddlExecutor.ExecuteDDL(dropSQL); err != nil {
 				return fmt.Errorf("删除表 %s 失败: %w", table.Name, err)
 			}
-			fmt.Printf("表 %s 已删除\n", table.Name)
+			log.Printf("表 %s 已删除\n", table.Name)
 
 			// 重新创建表
 			if err := tm.ddlExecutor.ExecuteDDL(table.SQL); err != nil {
 				return fmt.Errorf("创建表 %s 失败: %w", table.Name, err)
 			}
-			fmt.Printf("表 %s 已创建\n", table.Name)
+			log.Printf("表 %s 已创建\n", table.Name)
 		} else {
 			// 不存在直接创建
 			if err := tm.ddlExecutor.ExecuteDDL(table.SQL); err != nil {
 				return fmt.Errorf("创建表 %s 失败: %w", table.Name, err)
 			}
-			fmt.Printf("表 %s 已创建\n", table.Name)
+			log.Printf("表 %s 已创建\n", table.Name)
 		}
 	} else {
 		// 如果不存在就建立
@@ -163,42 +164,18 @@ func (tm *TableManager) syncTable(table generators.TableDDL, recreate bool) erro
 			if err := tm.ddlExecutor.ExecuteDDL(table.SQL); err != nil {
 				return fmt.Errorf("创建表 %s 失败: %w", table.Name, err)
 			}
-			fmt.Printf("表 %s 已创建\n", table.Name)
+			log.Printf("表 %s 已创建\n", table.Name)
 		} else {
-			fmt.Printf("表 %s 已存在，跳过创建\n", table.Name)
+			log.Printf("表 %s 已存在，跳过创建\n", table.Name)
 		}
 	}
 
 	return nil
 }
 
-// CreateTables 创建所有表（不存在则创建）
-func (tm *TableManager) CreateTables() error {
-	return tm.SyncTables(false)
-}
-
 // RecreateTables 重建所有表（存在则删除重建）
 func (tm *TableManager) RecreateTables() error {
-	return tm.SyncTables(true)
-}
-
-// CreateIndexes 创建索引
-func (tm *TableManager) CreateIndexes() error {
-	// 这里可以添加索引创建的逻辑
-	// 由于TableDDL中没有包含索引信息，所以暂时为空
-
-	// 暂时返回nil，表示索引创建成功（实际上是空的）
-	fmt.Println("创建索引方法（空实现）")
-	return nil
-}
-
-// CreateTablesAndIndexes 创建表及其索引（便捷方法）
-func (tm *TableManager) CreateTablesAndIndexes(recreateTables bool) error {
-	if err := tm.SyncTables(recreateTables); err != nil {
-		return err
-	}
-
-	return tm.CreateIndexes()
+	return tm.createTables(true)
 }
 
 // GetRegisteredTables 获取所有注册的表名
@@ -224,9 +201,9 @@ func (tm *TableManager) GetTableDDL(tableName string) (string, bool) {
 // PrintRegisteredTables 打印所有注册的表信息
 func (tm *TableManager) PrintRegisteredTables() {
 	tables := tm.GetRegisteredTables()
-	fmt.Printf("注册的表数量: %d\n", len(tables))
+	log.Printf("注册的表数量: %d\n", len(tables))
 	for i, name := range tables {
-		fmt.Printf("%d. %s\n", i+1, name)
+		log.Printf("%d. %s\n", i+1, name)
 	}
 }
 
@@ -234,17 +211,11 @@ func (tm *TableManager) PrintRegisteredTables() {
 // CreateAllTables 创建所有表（便捷函数，自动获取单例）
 func CreateAllTables(executor DDLExecutor) error {
 	tm := GetTableManagerWithExecutor(executor)
-	return tm.CreateTables()
-}
-
-// RecreateAllTables 重建所有表（便捷函数，自动获取单例）
-func RecreateAllTables(executor DDLExecutor) error {
-	tm := GetTableManagerWithExecutor(executor)
-	return tm.RecreateTables()
+	return tm.createTables(false)
 }
 
-// SyncAllTables 同步所有表（便捷函数，自动获取单例）
-func SyncAllTables(executor DDLExecutor, recreate bool) error {
+// DeleteAanCreateAllTables 删除并建立所有表（便捷函数，自动获取单例）
+func DeleteAanCreateAllTables(executor DDLExecutor) error {
 	tm := GetTableManagerWithExecutor(executor)
-	return tm.SyncTables(recreate)
+	return tm.createTables(true)
 }