|
@@ -135,21 +135,23 @@ func getDictIndex(sqlStatement string, pars []interface{}) (dictIndexs []DictInd
|
|
|
//sqlStatement := "SELECT * FROM DICT_INDEX WHERE SOURCE_TYPE = :1 AND ROWNUM < 11"
|
|
|
stmt, err := global.OracleJy.Prepare(sqlStatement)
|
|
|
if err != nil {
|
|
|
- panic(err)
|
|
|
+ err = fmt.Errorf("sql 预处理 失败,Err: %s", err)
|
|
|
+ return
|
|
|
}
|
|
|
rows, err := stmt.Query(pars...) //输入sql中对应参数的值
|
|
|
if err != nil {
|
|
|
- panic(err)
|
|
|
+ err = fmt.Errorf("sql 查询失败,Err: %s", err)
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
defer rows.Close() //defer关闭查询连接
|
|
|
//获取列相关信息
|
|
|
//获取列相关信息
|
|
|
strings, _ := rows.Columns()
|
|
|
-
|
|
|
+ global.LOG.Info("获取列表相关信息")
|
|
|
for i := 0; i < len(strings); i++ {
|
|
|
fmt.Print(" ", strings[i])
|
|
|
- global.LOG.Info(" ", strings[i])
|
|
|
+ global.LOG.Info("显示字段:", strings[i])
|
|
|
}
|
|
|
fmt.Print("\n")
|
|
|
global.LOG.Info("\n")
|
|
@@ -208,6 +210,7 @@ func getDictIndex(sqlStatement string, pars []interface{}) (dictIndexs []DictInd
|
|
|
if err != nil {
|
|
|
fmt.Printf("序列化错误 err = %v\n", err)
|
|
|
global.LOG.Info("序列化错误 err = %v\n", err)
|
|
|
+ return
|
|
|
}
|
|
|
//输出序列化后的结果 json字符串
|
|
|
fmt.Printf("序列化后 = %v\n", string(data))
|
|
@@ -221,11 +224,13 @@ func getDictData(sqlStatement string, pars []interface{}) (dictData []DictData,
|
|
|
//sqlStatement := "SELECT * FROM DICT_INDEX WHERE SOURCE_TYPE = :1 AND ROWNUM < 11"
|
|
|
stmt, err := global.OracleJy.Prepare(sqlStatement)
|
|
|
if err != nil {
|
|
|
- panic(err)
|
|
|
+ err = fmt.Errorf("sql 预处理 失败,Err: %s", err)
|
|
|
+ return
|
|
|
}
|
|
|
rows, err := stmt.Query(pars...) //输入sql中对应参数的值
|
|
|
if err != nil {
|
|
|
- panic(err)
|
|
|
+ err = fmt.Errorf("sql 查询失败,Err: %s", err)
|
|
|
+ return
|
|
|
}
|
|
|
|
|
|
defer rows.Close() //defer关闭查询连接
|