网站建设质量保证金/营销策划案

盈帆报表数据连接二次开发

一、在盈帆报表扩展新的数据连接，JAVA后台需要实现以下接口方法：

序号

方法名

参数

说明

1

testConnection

type:数据库类型

url:数据库链接url

username:用户名(HTTP接口无该参数)

password：密码(HTTP接口无该参

对于数据库来说，可以通过该方法来判断能否连接上指定的数据库

对于自定义HTTP接口来说，可以通过实现该方法来判断是否能链接到指定的HTTP接口

接口

2

connName:数据连接名

url:数据库链接

对于数据库来说，可以通过该方法链接指定的数据库。

对于自定义HTTP接口来说，可以通过实现该方法来链接指定的HTTP接口

来链接指

sql：数据库查询语句(HTTP接口无该参数)

fetchSize：(HTTP接口无该

对于数据库来说，可以通过该方法来初始化数据集

对于自定义HTTP接口来说，可以通过实现该方法来返回指定的接口数据集

说，可以通过实现该方法来返回指定的接口数据集

4

对于数据库来说，可以通过数据链接名来获取数据链接的URL

对于自定义HTTP接口来说，可以通过实现该方法来返回指定的url

HTTP接口来说，可以

type:数据库类型

url:数据库链接url

username:用户名(HTTP接口无该参数)

password：密码(HT

对于数据库来说，可以通过该方法获取到指定数据库里面的表名。

对于自定义HTTP接口来说，可以通过实现该方法来返回自定义的数据库表名

据库里面的表名。

对于自定义HT

connName:数据库连接名

sql:数据库查询语句(HTTP接口无该参数)

count

对于数据库来说，可以通过连接名和sql语句来获取分页数据。

对于自定义HTTP接口来说，可以通过实现该方法来返回自定义的列表数据

，可以通过连接名和sql语句来获取分页数据。

对于自定义HTTP接口来说，可以

对于数据库来说，可以通过sql语句来获取数据结果集的所有列名

对于自定义HTTP接口来说，可以通过实现该方法来返回自定义

据库来说，可以通过sql语句来获取数据结果集的所有列名

对

有列名

对

对于数据库来说，可以通过索引来获取数据结果集对应列的字段类型

对于自定义HTTP接口来说，可以通过实现该方法来返回自定义的字段类型数据

对于数据库来说，可以通过索引来获取数据结果集对应列的字段类

对于数据库来说，可以通过索引来获取数据结果集对应列的字段名

对于自定义HTTP接口来说，可以通过实现该方法来返回自定义的字段名数据

ex：索引

对于数据库来说，可

index：索引

type:字

对于数据库来说，可以通过索引和字段类型来获取数据结果集对应列的值

对于自定义HTTP接口来说，可以通过实现该方法来返

索引

type:字段类型

type:字段类型

对于

对于数据库来说，可以获取数据集列总数

对于自定义HTTP接口来说，可以通过实现该方法来返回对应的值

该方法来返回自定

对于数据库来说，可以关闭数据集

对于自定义HTTP接口来说

总数

对于自定义HT

总数

对于自定义HTTP接

HTTP接

对于数据库来说，可以关闭链接

对于自定义HT

以关闭数据集

对于自定义HTTP接口来说，可以通过实现该方法关闭数据集

P接口来说，可以通过实现该

对于数据库来说，可以关闭链接

对于自定义HTTP接口来说，可以通过实现该方法关闭链接

自定义HTTP接口来说，可以通过实现该方法关闭链接

二、 demo示例：

package com.efreport.database;

import com.alibaba.fastjson.JSONArray;

import com.alibaba.fastjson.JSONObject;

import org.apache.commons.io.FileUtils;

import java.io.*;

import java.lang.reflect.Method;

import java.net.HttpURLConnection;

import java.net.MalformedURLException;

import java.net.URL;

import java.sql.*;

import java.util.*;

public class SGCC {

public Connection connection; //链接

public ResultSet rs; // 结果集

public PreparedStatement ps; //

public JSONObject connObject = new JSONObject();

public String connFileName;

/**

* @描述 设置conn.xml文件的路径

* @参数 [fileName]

* @返回值 void

* @创建人

* @创建时间

* @修改人和其它信息

*/

public boolean setConnFileName(String fileName) {

try {

connFileName = fileName;

File jsonFile = new File(fileName);

FileInputStream fis = new FileInputStream(jsonFile); //解析内核文件

InputStreamReader inputStreamReader = new InputStreamReader(fis, "UTF-8");

BufferedReader in = new BufferedReader(inputStreamReader);

StringBuffer sb = new StringBuffer();

String str;

while ((str = in.readLine()) != null) {

sb.append(str);

}

in.close();

String jsonText = sb.toString();

JSONArray jsonArray = JSONArray.parseArray(jsonText);

for (int i = 0; i < jsonArray.size(); i++) {

JSONObject object = jsonArray.getJSONObject(i);

String name = object.getString("name");

connObject.put(name, object);

}

} catch (Exception e) {

return false;

}

return true;

}

public void setConnObject(JSONArray jsonArray) {

for (int i = 0; i < jsonArray.size(); i++) {

JSONObject object = jsonArray.getJSONObject(i);

String name = object.getString("name");

this.connObject.put(name, object);

}

}

;

/**

* @描述 根据conn.xml中的链接名来判断是否能链接上指定数据库

* @参数 [connName]

* @返回值 boolean

* @创建人

* @创建时间

* @修改人和其它信息

*/

public boolean connect(String connName, String url) {

JSONObject object = connObject.getJSONObject(connName); //获取链接信息

String username = object.getString("username"); //用户名

String password = object.getString("password"); //密码

String type = object.getString("type"); //类型

try {

connection = DriverManager.getConnection(url, username, password);

} catch (Exception e) {

return false;

}

return true;

}

/**

* @描述 根据conn.xml中的链接名来判断是否能链接上指定数据库

* @参数 [connName]

* @返回值 boolean

* @创建人

* @创建时间

* @修改人和其它信息

*/

public boolean connect(String url, String username, String password) {

try {

connection = DriverManager.getConnection(url, username, password);

} catch (Exception e) {

return false;

}

return true;

}

/**

* @描述 获取数据库中所有的表

* @参数 []

* @返回值 java.lang.String

* @创建人

* @创建时间

* @修改人和其它信息

*/

public static String getTableName(String type, String url, String username, String password) {

JSONArray tables = new JSONArray();

String sql = "SELECT TABLE_NAME FROM information_schema.tables WHERE table_schema = (select database()) AND table_type = 'base table'";

try {

Class.forName("sgcc.nds.jdbc.driver.NdsDriver");

Connection connection = DriverManager.getConnection(url, username, password);

PreparedStatement ps = connection.prepareStatement(sql);

ResultSet rs = ps.executeQuery(); //执行获得结果集

while (rs.next()) {

tables.add(rs.getString("TABLE_NAME"));

}

rs.close();

ps.close();

connection.close();

return tables.toJSONString();

} catch (Exception e) {

return null;

}

}

/**

* @描述 根据sql、页数、每页显示条数获取数据

* @参数 [sql, page, count]

* @返回值 java.util.List>

* @创建人

* @创建时间

* @修改人和其它信息

*/

public List> getResultsByPage(String connName, String sql, int count) {

JSONObject object = connObject.getJSONObject(connName); //根据连接名获取数据库链接对象

String type = object.getString("type"); //数据库类型

List> list = new ArrayList<>();

try {

Class.forName("sgcc.nds.jdbc.driver.NdsDriver");

ps = connection.prepareStatement(sql);

rs = ps.executeQuery(); // 返回查询结果集合

ResultSetMetaData metaData = rs.getMetaData(); // 获得列的结果

while (rs.next()) {

if (count > 0) {

Map map = new HashMap();

int cols_len = metaData.getColumnCount(); // 获取总的列数

for (int i = 0; i < cols_len; i++) {

String col_name = metaData.getColumnName(i + 1); // 获取第 i列的字段名称

Object col_value = rs.getObject(col_name); // 获取第i列的内容值

col_value = col_value == null ? "" : col_value.toString();

map.put(col_name, col_value);

}

list.add(map);

count--;

} else {

break;

}

}

} catch (Exception e) {

e.printStackTrace();

return null;

}

return list;

}

/**

* @描述 测试数据库链接

* @参数 [type 数据库类型, url 数据库URL, username 用户名, password 密码]

* @返回值 boolean

* @创建人

* @创建时间

* @修改人和其它信息

*/

public static boolean testConnection(String type, String url, String username, String password) {

try {

Class.forName("sgcc.nds.jdbc.driver.NdsDriver");

Connection connection = DriverManager.getConnection(url, username, password);

connection.close();

return true;

} catch (Exception e) {

return false;

}

}

/**

* @描述 根据指定的sql获取查询结果的所有字段名

* @参数 [sqlStr]

* @返回值 java.lang.String

* @创建人

* @创建时间

* @修改人和其它信息

*/

public String getFieldNames(String sqlStr) {

JSONArray names = new JSONArray(); //所有字段名

try {

PreparedStatement ps = connection.prepareStatement(sqlStr);

rs = ps.executeQuery();

ResultSetMetaData data = rs.getMetaData(); //获得结果集元数据

for (int i = 1; i <= data.getColumnCount(); i++) {

// 获得指定列的列名

String columnName = data.getColumnName(i);

names.add(columnName);

}

} catch (Exception e) {

return null;

}

return names.toString();

}

/**

* @描述 rs.next

* @参数 []

* @返回值 boolean

* @创建时间

* @修改人和其它信息

*/

public boolean next() {

try {

return rs.next();

} catch (Exception e) {

return false;

}

}

/**

* @描述 根据index获取字段类型

* @参数 [index]

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*/

public int getFieldTypeByIndex(int index) {

try {

ResultSetMetaData data = rs.getMetaData(); //获得结果集元数据

// 获得所有列的数目及实际列数

int columnType = data.getColumnType(index);

if (columnType == 1 || columnType == 12 || columnType == -1 || columnType == -9) {//STRING

return 1;

} else if (columnType == -7 || columnType == -6 || columnType == 5 || columnType == 4 || columnType == -5) {//INT

return 2;

} else if (columnType == 8 || columnType == 2 || columnType == 3 || columnType == 6 || columnType == 7) {//DOUBLE

return 3;

} else if (columnType == 91 || columnType == -15 || columnType == -16) {//Date

return 4;

} else if (columnType == 92 || columnType == 93) {//Time

return 5;

} else if (columnType == 16) {//BOOLEAN

return 6;

} else {

return 1;

}

} catch (Exception e) {

return 0;

}

}

/**

* @描述 根据index获取字段名称

* @参数 [index]

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*/

public String getFieldNameByIndex(int index) {

try {

ResultSetMetaData data = rs.getMetaData(); //获得结果集元数据

// 获得所有列的数目及实际列数

String columnType = data.getColumnName(index);

//整型

return columnType;

} catch (Exception e) {

return null;

}

}

/**

* @描述 根据index和type获取字段值

* @参数 [index], [type]

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*/

public String getValueByIndex(int index, int type) {

//int type = getFieldTypeByIndex(index);

try {

if (type == 1) {

String value = rs.getString(index);

return value == null ? "" : value;

} else if (type == 2) {

String value = rs.getString(index);

return value == null ? "" : value;

} else if (type == 3) {

String value = rs.getString(index);

return value == null ? "" : value;

} else if (type == 4) {//date

Timestamp timestamp = rs.getTimestamp(index);

if (timestamp == null) {

return "";

} else {

long time = timestamp.getTime();

return String.valueOf(time);

}

//return timestamp==null?"":timestamp.toString();

} else if (type == 5) {//time

Timestamp timestamp = rs.getTimestamp(index);

if (timestamp == null) {

return "";

} else {

long time = timestamp.getTime();

return String.valueOf(time);

}

} else if (type == 6) {

return rs.getString(index) == null ? "" : rs.getString(index);

} else {

return null;

}

} catch (Exception e) {

return null;

}

}

/* *//**

* @描述 根据name获取字段类型

* @参数 [index]

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*//*

public int getFieldTypeByName(String name) {

return 0;

}

*//**

* @描述 根据name获取字段值

* @参数 [index]

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*//*

public String getValueByName(String name) {

return null;

}*/

/**

* @描述 根据sql打开新的prepareStatement, resultSet

* @参数 [sql]

* @返回值 boolean

* @创建人

* @创建时间

* @修改人和其它信息

*/

public boolean open(String sql, int fetchSize) {

//当SQL语句里面含有以下这些关键字时，不执行

String[] excludeSql = new String[]{"delete ", "update ", "drop ", "insert ", "select into"};

for (int i = 0; i < excludeSql.length; i++) {

String key = excludeSql[i];

if (sql.contains(key)) {

return false;

}

}

try {

ps = connection.prepareStatement(sql);

ps.setFetchSize(fetchSize);

rs = ps.executeQuery();

} catch (Exception e) {

return false;

}

return true;

}

/**

* @描述 关闭当前连接里面的prepareStatement, resultSet

* @参数 []

* @返回值 boolean

* @创建人

* @创建时间

* @修改人和其它信息

*/

public boolean close() {

try {

rs.close();

ps.close();

return true;

} catch (Exception e) {

return false;

}

}

/**

* @描述 获取当前结果集的列总数

* @参数 []

* @返回值 int

* @创建人

* @创建时间

* @修改人和其它信息

*/

public int getFieldCount() {

try {

ResultSetMetaData data = rs.getMetaData(); //获得结果集元数据

return data.getColumnCount();

} catch (Exception e) {

return 0;

}

}

/**

* @描述 根据连接名获取url

* @参数 [connName]

* @返回值 java.lang.String

* @创建人

* @创建时间

* @修改人和其它信息

*/

public String getConnURL(String connName) {

try {

JSONObject object = connObject.getJSONObject(connName); //获取链接信息

Class.forName("sgcc.nds.jdbc.driver.NdsDriver");

if (connObject == null || object == null) {

return null;

} else {

return object.getString("url");

}

} catch (Exception e) {

return null;

}

}

public boolean disConnect() {

try {

if (rs != null) {

rs.close();

}

if (ps != null) {

rs.close();

}

if (connection != null) {

connection.close();

}

return true;

} catch (Exception e) {

return false;

}

}

public static void main(String[] args) {

SGCC db = new SGCC();

String fileName = "d:" + File.separator + "conn.json";

db.setConnFileName(fileName);

JSONObject object = db.connObject;

try {

JSONObject obj = object.getJSONObject("redis");

db.connect("redis", obj.getString("url"));

String sql = "(StringTest , 1 , 2)";

db.open(sql, 10);

while (db.next()) {

System.out.println("FieldNames:" + db.getFieldNames(sql));

System.out.println("FieldCount:" + db.getFieldCount());

System.out.println("FieldName:" + db.getFieldNameByIndex(1));

int fieldType = db.getFieldTypeByIndex(1);

System.out.println("FieldType:" + db.getFieldTypeByIndex(1));

System.out.println("FieldValue:" + db.getValueByIndex(1, fieldType));

}

} catch (Exception e) {

}

}

三、部署

写好的class文件编译成.jar文件，将其所需要的其他连接库与本身放置服务器webappsEFReportWEB-INFlib目录下，再将本身jar放置webappsEFReportWEB-INFlibdb目录与webappsEFReportWEB-INFclassessqldrivers目录下。重新启动tomcat，即可在设计器中使用新写的数据库连接。