程序数据集问题 - 我的帆软

程序数据集问题

在程序数据集中可以直接写SQL吗

如

package com.fr.fj;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.Statement;

import java.util.ArrayList;

import com.fr.base.FRContext;

import com.fr.base.Parameter;

import com.fr.data.AbstractTableData;

public class KL_gc2 extends AbstractTableData {

    private static final long serialVersionUID = -8214349138327797954L;

    // 列名数组，保存程序数据集所有列名

    private String[] columnNames = null;

    // 定义程序数据集的列数量

    private int columnNum = 12;

    // 保存查询表的实际列数量

    private int colNum = 0;

    // 保存查询得到列值

    @SuppressWarnings("rawtypes")

    private ArrayList valueList = null;

    private String ck = null;

    private String rq = null;

    // 构造函数，定义表结构

    public KL_gc2() {

        // 定义参数

               FineReport
               wxx2466
       发布于 2019-8-2 09:36
       （编辑于 2019-8-2 09:55）
     

1min目标场景问卷

立即参与

回答问题关注问题

悬赏：4 F币 + 添加悬赏

提示：增加悬赏、完善问题、追问等操作，可使您的问题被置顶，并向所有关注者发送通知

共1回答

最佳回答

firegunzxLv6高级互助
发布于2019-8-2 09:37（编辑于 2019-8-2 10:02）

KL_gc2.zip

可以的

我之前都通过程序数据集写sql抽取不同数据库的数据到中间表再查询出来，相当于做了一个小型ETL

举报收起评论(17)

wxx2466(提问者) 是的我是这样操作的，但是预览的时候不显示数据，不知道是哪里出问题了

2019-08-02 09:39

wxx2466(提问者) 有没有列子可以参考一下

2019-08-02 09:41

firegunzx 回复 wxx2466(提问者) 程序是怎么写的？我看下代码

2019-08-02 09:41

wxx2466(提问者) 回复 firegunzx package com.fr.data; import com.fr.base.FRContext; import com.fr.file.DatasourceManager; import com.fr.stable.ParameterProvider; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.Statement; import java.util.ArrayList; //import java.util.*; /** * 带参数的程序数据集Demo * * @author fanruan */ @SuppressWarnings(\"unchecked\") public class DataDemo extends AbstractTableData { /** * 列名数组，保存程序数据集所有列名 */ private String[] columnNames; /** * 定义程序数据集的列数量 */ private int columnNum = 10; /** * 保存查询表的实际列数量 */ private int colNum = 0; /** * 保存查询得到列值 */ private ArrayList valueList = null; /** * 构造函数，定义表结构，该表有10个数据列，列名为column#0，column#1，。。。。。。column#9 */ public DataDemo() { columnNames = new String[columnNum]; for (int i = 0; i < columnNum; i++) { columnNames[i] = \"column#\" + String.valueOf(i); } } /** * 实现其他四个方法 * * @return columnNum */ @Override public int getColumnCount() { return columnNum; } @Override public String getColumnName(int columnIndex) { return columnNames[columnIndex]; } @Override public int getRowCount() { init(); return valueList.size(); } @Override public Object getValueAt(int rowIndex, int columnIndex) { init(); if (columnIndex >= colNum) { return null; } return ((Object[]) valueList.get(rowIndex))[columnIndex]; } /** * 准备数据 */ private void init() { // 确保只被执行一次 if (valueList != null) { return; } // 保存得到的数据库表名 \\\\String tableName = ((ParameterProvider) (parameters.get().toArray())[0]).getValue().toString(); // 构造SQL语句,并打印出来 String sql = \"select * from unit\"; FRContext.getLogger().info(\"Query SQL of ParamTableDataDemo: \\n\" + sql); // 保存得到的结果集 valueList = new ArrayList(); // 下面开始建立数据库连接，按照刚才的SQL语句进行查询 com.fr.data.impl.Connection conn = DatasourceManager.getInstance().getConnection(\"JDBC\"); try { Connection con = conn.createConnection(); Statement stmt = con.createStatement(); ResultSet rs = stmt.executeQuery(sql); // 获得记录的详细信息，然后获得总列数 ResultSetMetaData rsmd = rs.getMetaData(); colNum = rsmd.getColumnCount(); // 用对象保存数据 Object[] objArray = null; while (rs.next()) { objArray = new Object[colNum]; for (int i = 0; i < colNum; i++) { objArray[i] = rs.getObject(i + 1); } // 在valueList中加入这一行数据 valueList.add(objArray); } // 释放数据库资源 rs.close(); stmt.close(); con.close(); // 打印一共取到的数据行数量 } catch (Exception e) { e.printStackTrace(); } } /** * 获取数据库连接 driverName和 url 可以换成您需要的 * * @return Connection */ public Connection getConnection() { String driverName = \"oracle.jdbc.OracleDriver\"; String url = \"jdbc:oracle:thin:@172.224.404.146:1521:orcl\"; String username = \"sms2\"; String password = \"w12333\"; Connection con; try { Class.forName(driverName); con = DriverManager.getConnection(url, username, password); } catch (Exception e) { e.printStackTrace(); return null; } return con; } /** * 释放一些资源，因为可能会有重复调用，所以需释放valueList，将上次查询的结果释放掉 * * @throws Exception e */ @Override public void release() throws Exception { super.release(); this.valueList = null; } }

2019-08-02 09:43