示例3- 自定义数据集-客户化文档
目录
本节目录收起
  • 业务场景-获取数据集参数
  • 示例代码
  • 示例3

    业务场景-获取数据集参数

    建立自定义数据集时,可以设置传入数据集的参数,如下图所示:

    可以在代码中通过CustomDataSetConfig类,获取到这些参数,但注意这样获取到的参数值仅是在数据集设置窗口中所设定的默认值,而不是查询报表时动态传入的参数值。

    示例代码

    自定义数据集获取系统的demo数据源,读取自定义数据集参数“sql”,例如该参数值设置为“SELECT DEMO_EMPLOYEE.雇员ID,DEMO_EMPLOYEE.名字,DEMO_EMPLOYEE.出生日期,DEMO_EMPLOYEE.职务 FROM DEMO_EMPLOYEE WHERE DEMO_EMPLOYEE.名字 =”,读取参数“empName”,例如该参数值设置为“伟”,将两个参数拼成完整的sql语句执行后获取结果,转化为dataset对象。

    自定义数据集实现代码如下:

    package com.api;

     

    import java.sql.Connection;

    import java.sql.ResultSet;

    import java.sql.ResultSetMetaData;

    import java.sql.SQLException;

    import java.sql.Statement;

     

    import com.runqian.report4.usermodel.*;

    import com.runqian.report4.dataset.*;

     

    /**
     * @author jade 用自定义数据集实现连接系统数据源demo,获取定义数据集时设置的参数值,拼成sql语句,
     *         对拼好的sql语句执行查询,生成dataset对象
     */

    public class MyDataSetDsc implements IDataSetFactory {

        Connection con = null;

        Statement stmt = null;

     

        public DataSet createDataSet(Context ctx, DataSetConfig dsc, boolean retrieve) {

           con = getConnection(ctx, dsc);

           // 通过ctx获取数据库连接
           // 执行sql语句,返回结果对象resultset

           String sql = getSql(ctx, dsc);

           ResultSet rs = getRs(con, sql);

           // 创建dataset

           DataSet ds = new DataSet(null);

           try {

               System.out.println("开始创建dataset");

               // 获取物理表列名称,用做自定义数据集的列名

               ResultSetMetaData md = rs.getMetaData();

               int cols = md.getColumnCount();

               // 创建列名

               for (int i = 1; i <= cols; i++) {

                  System.out.println(md.getColumnName(i));

                  ds.addCol(md.getColumnName(i));

                 

               }

               // 创建row

               while (rs.next()) {

                  Row row = ds.addRow();

                  for (int i = 1; i <= cols; i++) {

                      row.setData(i, rs.getString(i));

                  }

                  System.out.println("创建成功");

               }

           } catch (Exception e) {

               e.printStackTrace();

           }

           // 关闭各种对象

           release(rs, stmt, con);

           return ds;

        }

     

        // 从自定义数据集设置中读取设置的参数值 sql和empName

        public String getSql(Context ctx, DataSetConfig dsc) {

           CustomDataSetConfig cdsc = (CustomDataSetConfig) dsc;

           StringBuffer sb = new StringBuffer();

           //获取参数值数组,拼成完整sql语句

           String[] values = cdsc.getArgValue();

           sb.append(values[0]).append("'").append(values[1]).append("'");

           System.out.println(sb.toString());

           return sb.toString();

        }

     

        // 获取数据库连接

        public Connection getConnection(Context ctx, DataSetConfig dsc) {

           try {

               //获取demo数据源连接

               IConnectionFactory icf = ctx.getInitCtx().getConnectionFactory("demo");

               con=icf.getConnection();

               System.out.println("得到的数据源是:" + con);

           } catch (Exception ex) {

               ex.printStackTrace();

           }

           return con;

        }

     

        // 获取执行sql后的结果集

        public ResultSet getRs(Connection con, String sql) {

           ResultSet rs = null;

           try {

               stmt = con.createStatement();

               rs = stmt.executeQuery(sql);

           } catch (SQLException e) {

               // TODO Auto-generated catch block

               e.printStackTrace();

           }

           return rs;

        }

     

        // 释放连接类

        public static void release(ResultSet rs, Statement stmt, Connection con) {

           try {

               if (rs != null)

                  rs.close();

           } catch (Exception e) {

               e.printStackTrace();

           }

           try {

               if (stmt != null)

                  stmt.close();

           } catch (Exception e) {

               e.printStackTrace();

           }

           try {

               if (con != null)

                  con.close();

           } catch (Exception e) {

               e.printStackTrace();

           }

        }

    }