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

refactor: db元信息获取调整

Browse Source
This commit is contained in:
meilin.huang
2022-10-16 11:14:13 +08:00
parent 575947795a
commit c35e91b7b6
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/internal/db/application/mysql_meta.go
View File

@@ -36,7 +36,8 @@ type MysqlMetadata struct {
// 获取表基础元信息, 如表名等
func (mm *MysqlMetadata) GetTables() []map[string]interface{} {
_, res, _ := mm.di.SelectData(MYSQL_TABLE_MA)
res, err := mm.di.innerSelect(MYSQL_TABLE_MA)
biz.ErrIsNilAppendErr(err, "获取表基本信息失败: %s")
return res
}

9
server/internal/db/application/pgsql_meta.go
View File

@@ -44,7 +44,8 @@ type PgsqlMetadata struct {
// 获取表基础元信息, 如表名等
func (pm *PgsqlMetadata) GetTables() []map[string]interface{} {
_, res, _ := pm.di.SelectData(PGSQL_TABLE_MA)
res, err := pm.di.innerSelect(PGSQL_TABLE_MA)
biz.ErrIsNilAppendErr(err, "获取表基本信息失败: %s")
return res
}
@@ -73,13 +74,15 @@ func (pm *PgsqlMetadata) GetPrimaryKey(tablename string) string {
// 获取表信息，比GetTables获取更详细的表信息
func (pm *PgsqlMetadata) GetTableInfos() []map[string]interface{} {
_, res, _ := pm.di.SelectData(PGSQL_TABLE_INFO)
res, err := pm.di.innerSelect(PGSQL_TABLE_INFO)
biz.ErrIsNilAppendErr(err, "获取表信息失败: %s")
return res
}
// 获取表索引信息
func (pm *PgsqlMetadata) GetTableIndex(tableName string) []map[string]interface{} {
_, res, _ := pm.di.SelectData(fmt.Sprintf(PGSQL_INDEX_INFO, tableName))
res, err := pm.di.innerSelect(fmt.Sprintf(PGSQL_INDEX_INFO, tableName))
biz.ErrIsNilAppendErr(err, "获取表索引信息失败: %s")
return res
}