如何将 Liferay Service Builder 与远程 DB 和 JOIN 一起使用？

Question

我的 portlet 连接到远程数据库并使用多个 JOIN 执行复杂查询。我在论坛中询问如何在我的 portlet 中使用连接池，他们只是回答说我无论如何都应该使用 Service Builder，因为 SB 会处理这个问题......所以我的问题是，这是否正确以及我必须如何使用Service Builder 来完成我前面提到的用例。谢谢！

Answer 1

最后，我想出了一种使用连接池的方法。我不使用服务生成器，而是使用c3p0 池化库。

连接池.java

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

import com.liferay.portal.kernel.log.Log;
import com.liferay.portal.kernel.log.LogFactoryUtil;
import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;

public class ConnectionPool {

    private static Log _log = LogFactoryUtil.getLog(ConnectionPool.class);

    private static ConnectionPool _instance = new ConnectionPool();

    private ComboPooledDataSource _cpds;
    private Properties _props;

    public static void cleanUp(Connection con) {
        _instance._cleanUp(con);
    }

    public static void cleanUp(Connection con, Statement s) {
        _instance._cleanUp(con, s);
    }

    public static void cleanUp(Connection con, Statement s, ResultSet rs) {
        _instance._cleanUp(con, s, rs);
    }

    public static void cleanUp(Statement s) {
        _instance._cleanUp(s);
    }

    public static void destroy() throws SQLException {
        _instance._destroy();
    }

    public static Connection getConnection() throws SQLException {
        return _instance._getConnection();
    }

    public static Properties getProperties() {
        return _instance._props;
    }

    private ConnectionPool() {
        try {

            // Properties

            ClassLoader classLoader = getClass().getClassLoader();
            _props = new Properties();
            _props.load(classLoader.getResourceAsStream("connection-pool.properties"));

            _props.list(System.out);

            // Pooled data source
            String driverClass = _props.getProperty("driver.class");
            String jdbcUrl = _props.getProperty("jdbc.url");
            String user = _props.getProperty("user");
            String password = _props.getProperty("password");

            int minPoolSize = 5;

            try {
                minPoolSize = Integer.parseInt(_props.getProperty("min.pool.size"));
            } catch (Exception e) {
            }

            int maxPoolSize = 5;

            try {
                maxPoolSize = Integer.parseInt(_props.getProperty("max.pool.size"));
            } catch (Exception e) {
            }

            int acquireIncrement = 5;

            try {
                acquireIncrement = Integer.parseInt(_props.getProperty("acquire.increment"));
            } catch (Exception e) {
            }

            _cpds = new ComboPooledDataSource();

            _cpds.setDriverClass(driverClass);
            _cpds.setJdbcUrl(jdbcUrl);
            _cpds.setUser(user);
            _cpds.setPassword(password);

            _cpds.setMinPoolSize(minPoolSize);
            _cpds.setMaxPoolSize(maxPoolSize);
            _cpds.setAcquireIncrement(acquireIncrement);
        } catch (Exception e) {
            _log.error(e);
        }
    }

    private void _cleanUp(Connection con) {
        _cleanUp(con, null, null);
    }

    private void _cleanUp(Connection con, Statement s) {
        _cleanUp(con, s, null);
    }

    private void _cleanUp(Connection con, Statement s, ResultSet rs) {
        try {
            if (rs != null) {
                rs.close();
            }
        } catch (SQLException sqle) {
            _log.error(sqle);
        }

        try {
            if (s != null) {
                s.close();
            }
        } catch (SQLException sqle) {
            _log.error(sqle);
        }

        try {
            if (con != null) {
                con.close();
            }
        } catch (SQLException sqle) {
            _log.error(sqle);
        }
    }

    private void _cleanUp(Statement s) {
        try {
            if (s != null) {
                s.close();
            }
        } catch (SQLException sqle) {
            _log.error(sqle);
        }
    }

    private void _destroy() throws SQLException {
        DataSources.destroy(_cpds);
    }

    private Connection _getConnection() throws SQLException {
        return _cpds.getConnection();
    }

}

连接池.properties

driver.class=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://host/DB
user=123
password=123

min.pool.size=5
max.pool.size=20
acquire.increment=5

用法

conn = ConnectionPool.getConnection();