go/core
go/core
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

db - amend SizeTable method

Browse Source
This commit is contained in:
Mahdi Abu Yasmine 2023-12-02 14:07:53 +01:00
parent c3de6a3814
commit d0cb5d8502
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
db/db.go
View File

@ -176,7 +176,7 @@ type TableSize struct {
} }
func (db *Db) SizeTable(dbname string) []TableSize { func (db *Db) SizeTable(dbname string) []TableSize {
rs := make([]TableSize, 1) rs := make([]TableSize, 0)
db.onDbExec("information_schema", func(sqlDb *sql.DB) bool { db.onDbExec("information_schema", func(sqlDb *sql.DB) bool {
query := "SELECT `TABLE_NAME` AS `table`, ROUND(((`DATA_LENGTH` + `INDEX_LENGTH`) / 1024 / 1024), 2) `size` FROM `TABLES` WHERE `table_schema` = ? AND (`DATA_LENGTH` + `INDEX_LENGTH`) > 0 ORDER BY (`DATA_LENGTH` + `INDEX_LENGTH`) DESC;" query := "SELECT `TABLE_NAME` AS `table`, ROUND(((`DATA_LENGTH` + `INDEX_LENGTH`) / 1024 / 1024), 2) `size` FROM `TABLES` WHERE `table_schema` = ? AND (`DATA_LENGTH` + `INDEX_LENGTH`) > 0 ORDER BY (`DATA_LENGTH` + `INDEX_LENGTH`) DESC;"
rows, err := sqlDb.Query(query, dbname) rows, err := sqlDb.Query(query, dbname)
@ -191,9 +191,7 @@ func (db *Db) SizeTable(dbname string) []TableSize {
fmt.Printf("cannot get table size of db %s : %v", dbname, err) fmt.Printf("cannot get table size of db %s : %v", dbname, err)
return false return false
} }
if len(ts.Table) > 0 { rs = append(rs, ts)
rs = append(rs, ts)
}
} }
return true return true
}) })