Java調用MySql數據庫函數

    /**
     * 調用mysql的自定義函數
     * 
     */
    private void test() {
        logger.info("show task start ");
        Connection conn = null;
        CallableStatement cs = null;
        try {
            conn = Pub.getConnMysql();
             //調用存儲過程
            conn.setAutoCommit(false);
            cs = conn.prepareCall("{call " + db+ ".P_TEST()}");
            cs.executeQuery();
            conn.commit();
        }catch (Exception e) {
            logger.info("Exception: "+e.getMessage());
        }finally{
            try {
                cs.close();
            } catch (Exception ignore) {
                logger.info("Exception："+ignore.getMessage());
                ignore.printStackTrace();
            }
            Pub.CloseConnect(conn);
        }
        logger.info("show task end ");
    }