From 3f6541199b0246c93515739ece0db4c0df2a57f1 Mon Sep 17 00:00:00 2001
From: zack <zack@fanruan.com>
Date: Thu, 29 Apr 2021 09:42:09 +0800
Subject: [PATCH] =?UTF-8?q?REPORT-50963=20=E4=BC=98=E5=8C=96=E7=A8=8B?=
 =?UTF-8?q?=E5=BA=8F=E6=95=B0=E6=8D=AE=E9=9B=86=E4=B8=8A=E5=B1=82=E8=AE=BE?=
 =?UTF-8?q?=E8=AE=A1(abstracttabledata)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/fr/data/ParamTableDataDemo.java    | 17 ++++++++++++++---
 .../com/fr/data/SimpleParamTableDataDemo.java   |  6 +++++-
 2 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/fr/data/ParamTableDataDemo.java b/src/main/java/com/fr/data/ParamTableDataDemo.java
index 2d7f562..1cd5251 100644
--- a/src/main/java/com/fr/data/ParamTableDataDemo.java
+++ b/src/main/java/com/fr/data/ParamTableDataDemo.java
@@ -4,10 +4,12 @@ import com.fr.base.FRContext;
 import com.fr.file.DatasourceManager;
 import com.fr.log.FineLoggerFactory;
 import com.fr.stable.ParameterProvider;
+
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.ArrayList;
 
@@ -93,10 +95,11 @@ public class ParamTableDataDemo extends AbstractTableData {
         // 保存得到的结果集
         valueList = new ArrayList();
         // 下面开始建立数据库连接，按照刚才的SQL语句进行查询
+        // 根据连接名获取FR数据连接定义的数据连接，如果没有定义，也可以参考getConnection方法自己创建连接
         com.fr.data.impl.Connection conn = DatasourceManager.getInstance().getConnection("FRDemo");
-
+        Connection con = null;
         try {
-            Connection con = conn.createConnection();
+            con = conn.createConnection();
             Statement stmt = con.createStatement();
             ResultSet rs = stmt.executeQuery(sql);
             // 获得记录的详细信息，然后获得总列数
@@ -119,7 +122,15 @@ public class ParamTableDataDemo extends AbstractTableData {
             // 打印一共取到的数据行数量
 
         } catch (Exception e) {
-            e.printStackTrace();
+            FineLoggerFactory.getLogger().error(e.getMessage(), e);
+        } finally {
+            if (con != null) {
+                try {
+                    con.close();
+                } catch (SQLException e) {
+                    FineLoggerFactory.getLogger().error(e.getMessage(), e);
+                }
+            }
         }
     }
 
diff --git a/src/main/java/com/fr/data/SimpleParamTableDataDemo.java b/src/main/java/com/fr/data/SimpleParamTableDataDemo.java
index 0bb630e..44263a1 100644
--- a/src/main/java/com/fr/data/SimpleParamTableDataDemo.java
+++ b/src/main/java/com/fr/data/SimpleParamTableDataDemo.java
@@ -1,5 +1,6 @@
 package com.fr.data;
 
+import com.fr.file.ConnectionConfig;
 import com.fr.log.FineLoggerFactory;
 import com.fr.stable.ParameterProvider;
 
@@ -38,9 +39,12 @@ public class SimpleParamTableDataDemo extends SimpleTableData {
         FineLoggerFactory.getLogger().info("Query SQL of ParamTableDataDemo: \n" + sql);
         // 保存得到的结果集
         ArrayList<Object[]> valueList = new ArrayList();
+        // 下面开始建立数据库连接，按照刚才的SQL语句进行查询
+        // 根据连接名获取FR数据连接定义的数据连接，如果没有定义，也可以参考getConnection方法自己创建连接
+        com.fr.data.impl.Connection conn = ConnectionConfig.getInstance().getConnection("FRDemo");
         Connection con = null;
         try {
-            con = getConnection();
+            con = conn.createConnection();
             Statement stmt = con.createStatement();
             ResultSet rs = stmt.executeQuery(sql);
             // 获得记录的详细信息，然后获得总列数