对JDBC连接Oracle的简单封装

@(Java)代码片段

数据库是经常会涉及到的，对于JDBC来说，已经是对数据库连接提供了非常好的支持，但对于每次连接数据库都要写一大堆代码实现，这显然不符合一个好的程序员的习惯，而且由于每次连接数据库都是比较耗费资源的，所以为了对代码的重用和对系统性能的提高，对JDBC数据库的连接进行封装，是在所难免的，下面是封装的数据库，有不足的请指出改正，谢谢交流！

DataPage

涉及的是从数据库获取分页数据库时，所包含的信息，包括当前页码、每页记录数、总页数、总记录数、当前页数据等

package com.nlte.common.utils;

import java.sql.ResultSet;
import java.util.List;

/**
 * Created by hp on 2016/11/11.
 */
public class DataPage {

    private int curPage = 0;//当前页码
    private int pageSizes = 20;//每页记录数
    private int pages;//总页数
    private int totalRows; //总记录数
    private ResultSet data;//当前页数据

    public int getTotalRows() {
        return totalRows;
    }

    public void setTotalRows(int totalRows) {
        this.totalRows = totalRows;
    }

    public int getPages() {
        return pages;
    }

    public void setPages(int pages) {
        this.pages = pages;
    }

    public int getPageSizes() {
        return pageSizes;
    }

    public void setPageSizes(int pageSizes) {
        this.pageSizes = pageSizes;
    }

    public int getCurPage() {
        return curPage;
    }

    public void setCurPage(int curPage) {
        this.curPage = curPage;
    }

    public ResultSet getData() {
        return data;
    }

    public void setData(ResultSet data) {
        this.data = data;
    }
}

DaoException

自定义异常，方便对所遇到异常的描述

package com.nlte.common.exception;

/**
 * Created by hp on 2016/11/11.
 */
public class DaoException extends Exception {
    public DaoException() {
        super();
    }

    public DaoException(String msg) {
        super(msg);
    }

    public DaoException(Throwable arg) {
        super(arg);
    }
}

DBUtil

封装类，把对数据的操作进行封装，方便操作

package com.nlte.common.utils;

import com.nlte.common.exception.DaoException;
import oracle.jdbc.OracleTypes;

import java.sql.*;

/**
 * 对Oracle数据库连接的封装工具类
 * Created by hp on 2016/11/11.
 */
public class DBUtil {
    //Oracle驱动包
    private static final String driver = "oracle.jdbc.driver.OracleDriver";
    //连接Oracle数据库的URL
    // TODO: 2016/11/11 对于数据库URL、用户名、密码可以动态输入 
    private static String url = "jdbc:oracle:thin:localhost:1521:orcl";
    //数据库用户名
    private static String username = "scott";
    //数据库密码
    private static String pwd = "tiger";

    //连接对象
    private static Connection conn;
    //参数语句对象
    private static PreparedStatement ps;

    /**
     * 获取连接对象
     *
     * @return 连接对象
     * @throws DaoException 创建对象时抛出的异常
     */
    public static Connection getConnection() throws DaoException {
        try {
            //加载驱动Oracle的jdbc驱动包
            Class.forName(driver);

            //建立连接 ：制定连接到哪里去jdbc:oracle:thin:  ip地址 : 端口号 : 服务
            conn = DriverManager.getConnection(url, username, pwd);

            if (conn != null) {
                System.out.println("连接成功");
            }
        } catch (ClassNotFoundException e) {
            throw new DaoException("驱动加载失败，请检查驱动包");
        } catch (SQLException e) {
            throw new DaoException("连接数据库服务器失败，请检查网络或相关参数");
        }
        return conn;
    }

    /**
     * 只关闭连接
     */
    public static void close() {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭传入的连接
     *
     * @param conn 连接对象
     */
    public static void close(Connection conn) {
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 关闭指定的连接和参数语句对象
     *
     * @param conn 连接对象
     * @param ps   参数语句对象
     */
    public static void close(Connection conn, PreparedStatement ps) {

        try {
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {

                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 关闭连接和参数语句对象及结果集
     *
     * @param conn      连接对象
     * @param ps        参数语句对象
     * @param resultSet 结果集
     */
    public static void close(Connection conn, PreparedStatement ps, ResultSet resultSet) {
        try {
            if (resultSet != null) {
                resultSet.close();
            }
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 关闭最近获得的连接和参数语句对象
     *
     * @param ps 参数语句对象
     */
    public static void close(PreparedStatement ps) {

        try {
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 关闭最近获得的连接和参数语句对象及结果集
     *
     * @param ps        参数语句对象
     * @param resultSet 结果集
     */
    public static void close(PreparedStatement ps, ResultSet resultSet) {

        try {
            if (resultSet != null) {
                resultSet.close();
            }
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 关闭最近获得的连接和最近参数语句对象及结果集
     *
     * @param resultSet 结果集
     */
    public static void close(ResultSet resultSet) {

        try {
            if (resultSet != null) {
                resultSet.close();
            }
            if (ps != null) {
                ps.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 关闭最近获取的连接和CallableStatement和结果集
     * @param prepareCall
     * @param resultSet 结果集
     */
    public static void Close(CallableStatement prepareCall,ResultSet resultSet){
        try {
            if (resultSet != null) {
                resultSet.close();
            }
            if (prepareCall != null) {
                prepareCall.close();
            }
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    /**
     * 支持参数查询并返回结果集
     *
     * @param sql     sql语句
     * @param objects 动态参数列表
     * @return 结果集
     * @throws DaoException 创建SQL语句对象抛出的异常
     */
    // TODO: 2016/11/11 可以将sql语句拆分，通过输入参数合成SQL语句 
    public static ResultSet search(String sql, Object... objects) throws DaoException {
        Connection conn = getConnection();
        ResultSet resultSet;
        try {
            ps = conn.prepareStatement(sql);
            for (int i = 0; i < objects.length; i++) {
                ps.setObject(i + 1, objects[i]);
            }
            resultSet = ps.executeQuery();
        } catch (SQLException e) {
            throw new DaoException("创建SQL语句对象失败");
        }
        return resultSet;
    }

    /**
     * 支持参数查询并返回一个对象
     * 类似select count(*) from emp;
     *
     * @param sql     sql语句
     * @param objects 动态参数列表
     * @return 查询到的对象
     * @throws DaoException 创建SQL语句对象抛出的异常
     */
    public static Object searchObjects(String sql, Object... objects) throws DaoException {
        Connection conn = getConnection();
        ResultSet resultSet;
        Object object = null;
        try {
            ps = conn.prepareStatement(sql);
            for (int i = 0; i < objects.length; i++) {
                ps.setObject(i + 1, objects[i]);
            }
            resultSet = ps.executeQuery();
            resultSet.next();
            object = resultSet.getObject(1);
            close(ps, resultSet);
        } catch (SQLException e) {
            throw new DaoException("创建SQL语句对象失败");
        }
        return object;
    }

    /**
     * 执行插入、删除、修改等更新数据库的操作
     *
     * @param sql     SQL语句
     * @param objects 参数化对象
     * @return 影响的行数
     * @throws DaoException 创建SQL语句对象抛出的异常
     */
    // TODO: 2016/11/11 可以将增、删、改等操作分开成独立的方法，并将sql语句拆分，通过输入参数合成SQL语句 
    public static int update(String sql, Object... objects) throws DaoException {
        conn = DBUtil.getConnection();
        int rows;
        try {
            ps = conn.prepareStatement(sql);
            for (int i = 0; i < objects.length; i++) {
                ps.setObject(i + 1, objects[i]);
            }
            rows = ps.executeUpdate();
            close(ps);
        } catch (SQLException e) {
            throw new DaoException("创建SQL语句对象失败");
        }
        return rows;
    }

    /**
     * 开启事务(多用于批量数据)
     *
     * @param conn 连接对象
     * @throws DaoException 开启食物出错抛出的异常
     */
    public static void beginTransction(Connection conn) throws DaoException {
        try {
            conn.setAutoCommit(false);//关闭事务自动提交机制
        } catch (SQLException e) {
            throw new DaoException("开启食物出错");
        }
    }

    /**
     * 提交事务
     *
     * @param conn 连接对象
     * @throws DaoException 提交食物出错抛出的异常
     */
    public static void commit(Connection conn) throws DaoException {
        try {
            conn.commit();
            conn.setAutoCommit(true);//恢复事务自动提交机制
        } catch (SQLException e) {
            throw new DaoException("事务提交失败");
        }
    }

    /**
     * 回滚事务
     *
     * @param conn 连接对象
     * @throws DaoException 回滚食物出错抛出的异常
     */
    public static void rollback(Connection conn) throws DaoException {
        try {
            conn.rollback();
            conn.setAutoCommit(true);
        } catch (SQLException e) {
            throw new DaoException("回滚事务失败");
        }
    }


    /**
     * @param tableName 表名，或子查询
     * @param fields    字段列表
     * @param strWhere 条件表达式
     * @param curPage  每页的记录数
     * @param pageSizes 当前页页码
     * @return 数据页对象
     * @throws DaoException 调用分页过程出错抛出的异常
     */
    public static DataPage getPage(String tableName,
                            String fields,
                            String strWhere,
                            String orderFiled,
                            int curPage,
                            int pageSizes) throws DaoException {
        DataPage dataPage = null;
        Connection conn = getConnection();
        String sql = "call Pagination(" +
                "?," +//1、表名，或子查询
                "?," +//2、字段列表
                "?," +//3、条件表达式
                "?," +//4、排序表达式
                "?," +//5、当前页页码
                "?," +//6、每页的记录数
                "?," +//7、总记录数   -- 输出参数
                "?," +//8、总页数，或页数（存储过程计算出来）-- 输出参数
                "?)";// 9、当前页的数据 --输出参数
        try {
            //创建存储过程
            CallableStatement prepareCall = conn.prepareCall(sql);

            int i = 1;
            //给存储过程的参数设置值
            prepareCall.setString(i++, tableName);
            prepareCall.setString(i++, fields);
            prepareCall.setString(i++, strWhere);
            prepareCall.setString(i++, orderFiled);
            prepareCall.setInt(i++, curPage);
            prepareCall.setInt(i++, pageSizes);
            //注册输出参数
            /*All OUT parameters must be registered before a stored procedure is executed.*/
            prepareCall.registerOutParameter(i++, Types.INTEGER);//总记录数
            prepareCall.registerOutParameter(i++, Types.INTEGER);//总页数
            prepareCall.registerOutParameter(i++, OracleTypes.CURSOR);////当前页的数据

            prepareCall.execute();//执行存储过程

            dataPage = new DataPage();

            //执行完后，获取输出参数
            //获取总记录数
            int totalRows = prepareCall.getInt(7);
            dataPage.setTotalRows(totalRows);

            //获取总页数
            int pages = prepareCall.getInt(8);
            dataPage.setPages(pages);

            //获取当前页的数据
            ResultSet resultSet = (ResultSet) prepareCall.getObject(9);

            dataPage.setData(resultSet);

            //close(prepareCall, resultSet);
        } catch (SQLException e) {
            throw new DaoException("调用分页过程出错");
        }
        return dataPage;
    }
}

存储过程

分页存储过程

CREATE OR REPLACE PROCEDURE Pagination
       (tableName          varchar2,   --表名
        fileds             varchar2,   --查询字段
        strWhere           varchar2,   --查询条件
        orderFiled         varchar2,   --排序的字段
        curPage            Number,     --当前页
        sizes              Number,     --每页显示记录条数
        totalRows          out Number, --总记录数
        pages              out Number, --总页数
        cur_out out sys_refcursor -- 系统预定义的游标类型
        )
        
--优点一：sys_refcursor，可以在存储过程中作为参数返回一个table格式的结构集
--（我把他认为是table类型，容易理解，其实是一个游标集）， cursor 只能用在存
--储过程，函数，包等的实现体中，不能做参数使用。

--优点二：sys_refcursor 这东西可以使用在包中做参数，进行数据库面向对象开放。

--sys_refcursor 不能用open，close ，fetch 进行操作


--支持多表连接查询，
--多表举例：
--tableName= "t1,t2"
--strWhere="t1.id=t2.id"
IS
   v_sql VARCHAR2(1000) := '';      --sql语句
   v_startRecord Number(4);         --开始显示的记录条数
   v_endRecord Number(4);           --结束显示的记录条数
   v_fileds VARCHAR2(1000) := fileds;
BEGIN

   --记录中总记录条数
   v_sql := 'SELECT TO_NUMBER(COUNT(*)) FROM ' || tableName ;
   IF strWhere IS NOT NULL or strWhere <> '' THEN
       v_sql := v_sql || ' WHERE ' || strWhere;
   END IF;
   EXECUTE IMMEDIATE v_sql INTO totalRows; --  EXECUTE IMMEDIATE立即执行


   --根据页大小计算总页数
   IF MOD(totalRows,sizes) = 0 THEN
       pages := totalRows / sizes;
   ELSE
       pages := totalRows / sizes + 1;
   END IF;

   --实现分页查询
   v_startRecord := (curPage - 1) * sizes + 1;
   v_endRecord := curPage * sizes;
   --处理所有列情况
   if fileds='*' then
      v_fileds:=tableName||'.'||fileds;
   end if;
   --生成基本sql
   v_sql := 'SELECT '|| v_fileds || ',rownum rn FROM ' || tableName ;
   IF strWhere IS NOT NULL or strWhere <> '' THEN
       v_sql := v_sql ||  ' WHERE '||strWhere;
   END IF;
   v_sql :='select * from ('|| v_sql ||') ';
   --指定记录集
   v_sql :=v_sql || ' where rn <= ' || v_endRecord || 'and rn >= ' || v_startRecord;
   
   IF orderFiled IS NOT NULL or orderFiled <> '' THEN
       v_sql := v_sql || ' ORDER BY ' || orderFiled;
   END IF;
   
   
    --DBMS_OUTPUT.put_line(v_sql);
    open cur_out for v_sql ;--用v_sql创建的游标赋值给cur_out游标
END Pagination;
/

最后编辑于：2017.12.04 12:51:59

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 194,088评论 5赞 459
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 81,715评论 2赞 371
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 141,361评论 0赞 319
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 52,099评论 1赞 263
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 60,987评论 4赞 355
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 46,063评论 1赞 272
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 36,486评论 3赞 381
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 35,175评论 0赞 253
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 39,440评论 1赞 290
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 34,518评论 2赞 309
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 36,305评论 1赞 326
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 32,190评论 3赞 312
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 37,550评论 3赞 298
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 28,880评论 0赞 17
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 30,152评论 1赞 250
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 41,451评论 2赞 341
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 40,637评论 2赞 335

对JDBC连接Oracle的简单封装

推荐阅读更多精彩内容