TRKJ/mayfly-go
2
0
Fork 0
mirror of https://gitee.com/dromara/mayfly-go synced 2025-11-04 08:20:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: 优化数据库导出速度

Browse Source
This commit is contained in:
wanli
2023-09-07 11:15:11 +08:00
parent ecd79a2e15
commit 4d2e110e1e
2 changed files with 3 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
server/internal/db/application/db.go
View File

@@ -313,13 +313,7 @@ func selectDataByDb(db *sql.DB, selectSql string) ([]string, []map[string]any, e
}
func walkTableRecord(db *sql.DB, selectSql string, walk func(record map[string]any, columns []string)) error {
tx, err := db.Begin()
if err != nil {
return err
}
defer tx.Rollback()
rows, err := tx.Query(selectSql)
rows, err := db.Query(selectSql)
if err != nil {
return err
}
@@ -362,9 +356,6 @@ func walkTableRecord(db *sql.DB, selectSql string, walk func(record map[string]a
walk(rowData, colNames)
}
if err := tx.Commit(); err != nil {
return err
}
return nil
}