diff --git a/server/internal/db/application/mysql_meta.go b/server/internal/db/application/mysql_meta.go
index e6398809..f1b43011 100644
--- a/server/internal/db/application/mysql_meta.go
+++ b/server/internal/db/application/mysql_meta.go
@@ -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
 }
 
diff --git a/server/internal/db/application/pgsql_meta.go b/server/internal/db/application/pgsql_meta.go
index e384ead2..b58f7e3b 100644
--- a/server/internal/db/application/pgsql_meta.go
+++ b/server/internal/db/application/pgsql_meta.go
@@ -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
 }