fisher

在前面說明過使用Script數(shù)據(jù)源來獲得web service數(shù)據(jù)源的做法，在實(shí)際操作中，發(fā)現(xiàn)雖然有BIRT的幫助文件，但同事對BIRT的Script數(shù)據(jù)源的使用還是不太理解，于是寫出下文以便幫助使用BIRT的高級(jí)特性

熟悉了BIRT的Script數(shù)據(jù)源之后，你會(huì)感嘆BIRT功能之強(qiáng)大，BIRT團(tuán)隊(duì)承諾在2.0中加入對數(shù)據(jù)庫連接池的支持，但目前為止，我們還只能通過Script數(shù)據(jù)源來支持連接池。

為了能夠自定義數(shù)據(jù)集合以及支持分頁查詢、多表查詢、數(shù)據(jù)庫連接池或者在DAO中使用Spring+Hibernate或從web Service獲取數(shù)據(jù)等高級(jí)特性，我們需要使用BIRT的Script數(shù)據(jù)源來獲得數(shù)據(jù)

下面通過一個(gè)示例說明如何使用BIRT的Script數(shù)據(jù)源來通過POJO獲取數(shù)據(jù)：

注：

為了使例子不至于因?yàn)檫^于簡單而無法說明情況（如同BIRT的Tutorial那樣），在這里我使用了一個(gè)簡單但完整的DAO層，可直接在項(xiàng)目中使用，同時(shí)也為避免過于復(fù)雜，本例中沒有使用Spring+Hibernate或Web Service獲得數(shù)據(jù)源，但從POJO中可很簡單的將其改為SH組合或WS。

一、一個(gè)簡單的數(shù)據(jù)庫訪問層

在開始我們浪費(fèi)些時(shí)間來描述一下DAO層的幾個(gè)類，以便后面在BIRT中使用它時(shí)有所了解。

首先在Eclipse中建立一個(gè)Tomcat項(xiàng)目，然后在src中建立一個(gè)com.bat.afp.DAOComm包用來封裝一個(gè)非常簡單的DAO類，如下：

其中DBUtil為數(shù)據(jù)庫連接類（數(shù)據(jù)庫為Oracle8），使用了DBCP作為數(shù)據(jù)庫連接池，并使用XML文件（dbconfig.xml）來配置數(shù)據(jù)庫連接池的信息

DBUtil代碼如下：

  1package com.bat.afp.DAOComm;
  2
  3import java.io.File;
  4import java.net.URL;
  5import java.sql.Connection;
  6import java.sql.DriverManager;
  7import java.sql.SQLException;
  8import org.apache.commons.dbcp.DriverManagerConnectionFactory;
  9import org.apache.commons.dbcp.PoolableConnectionFactory;
 10import org.apache.commons.dbcp.PoolingDriver;
 11import org.apache.commons.pool.impl.GenericObjectPool;
 12import org.apache.log4j.BasicConfigurator;
 13import org.apache.log4j.Logger;
 14import org.dom4j.Document;
 15import org.dom4j.DocumentException;
 16import org.dom4j.Element;
 17import org.dom4j.io.SAXReader;
 18
 19/**//**
 20 * @author liuyf
 21 */
 22public class DBUtil {
 23
 24    private static final Logger    logger        = Logger.getLogger(DBUtil.class);
 25
 26    private static DBUtil        instance;
 27
 28    private GenericObjectPool    connectionPool;
 29
 30    private static String        dbUrl;
 31
 32    private static String        user;
 33
 34    private static String        password;
 35
 36    private static int            connNumber    = 10;
 37    static
 38    {
 39        BasicConfigurator.configure();
 40        try
 41        {
 42            readConfig();
 43        }
 44        catch (DocumentException e)
 45        {
 46            e.printStackTrace();
 47        }
 48    }
 49
 50    private DBUtil()
 51    {
 52        try
 53        {
 54            initConnectionPool();
 55        }
 56        catch (SQLException e)
 57        {
 58            e.printStackTrace();
 59        }
 60        logger.debug("DBUtil init");
 61    }
 62
 63    /**//**
 64     * 讀取配置文件
 65     * 
 66     * @throws DocumentException
 67     */
 68    private static void readConfig() throws DocumentException
 69    {
 70        URL url = DBUtil.class.getClassLoader().getResource("dbconfig.xml");
 71        File file = new File(url.getFile());
 72        // File file = new File("dbconfig.xml");
 73        SAXReader reader = new SAXReader();
 74        Document document = reader.read(file);
 75        Element root = document.getRootElement();
 76        Element dbinfo = root.element("dbinfo");
 77        dbUrl = dbinfo.elementText("url");
 78        user = dbinfo.elementText("user");
 79        password = dbinfo.elementText("pwd");
 80        String numStr = dbinfo.elementText("connNumber");
 81        if (numStr != null)
 82            connNumber = Integer.parseInt(numStr);
 83    }
 84
 85    public static DBUtil getInstance()
 86    {
 87        if (instance == null)
 88            return instance = new DBUtil();
 89        else
 90            return instance;
 91    }
 92
 93    /**//**
 94     * 
 95     */
 96    private void initConnectionPool() throws SQLException
 97    {
 98        DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
 99        connectionPool = new GenericObjectPool(null, connNumber);
100        DriverManagerConnectionFactory connectionFactory = new DriverManagerConnectionFactory(dbUrl, user,
101                password);
102        PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(
103                connectionFactory, connectionPool, null, null, false, true);
104        PoolingDriver driver = new PoolingDriver();
105        driver.registerPool("afpdb", connectionPool);
106    }
107
108    public Connection getConnection() throws SQLException
109    {
110        return DriverManager.getConnection("jdbc:apache:commons:dbcp:afpdb");
111    }
112}
113