一、理解和使用数据源

一、问题引入

现在我们能够使用JDBC访问数据库了，这种实现方式是否存在不足？

分析：
1、访问前需要先获取连接
2、每次操作结束后，要释放资源
3、频繁的连接导致系统的安全性和稳定性差

可以使用数据源和连接池解决上述问题。

二、连接池与数据源

2.1连接池工作原理

你不是嫌每次访问的时候创建连接、关闭连接费劲吗？那就干脆这样子：在访问数据库的时候先创建好一些连接，把这些连接放在连接池里面，通过连接池管理这些连接对象，然后当用户对数据库进行操作的时候，应用程序要进行连接了，我就在连接池里面拿一个连接给你，你不用创建了，你直接用就好；当你不用这个连接的时候，连接池会自动回收进行管理，你不需要手动地去释放资源，所以连接池就可以很好地解决上面提出的问题。


image.png

连接池是由容器提供的，用来管理池中连接对象。连接池自动分配连接对象并对闲置的连接进行回收。

那连接池里面的连接对象是由谁创建的呢？
是由数据源创建的。

2.2数据源（DataSource）

  • javax.sql.DataSource接口负责建立与数据库的连接。
  • 由Tomcat提供，将连接保存在连接池中

综上，数据源和连接池的关系如下：
1、数据源用来连接数据库，获得连接（Connection）对象
2、连接池用来管理连接（Connection）对象
3、在程序中使用JNDI获取数据源（需要在程序中写出的，记住代码即可）
4、JNDI——>DataSource——>Connection——>连接池

三、连接池和数据源的使用

3.1配置Tomcat获取数据源

配置tomcat：


image.png

将第一步中的代码复制到conf/context.xml。
代码如下：

<Resource name="jdbc/news"
              auth="Container"  type="javax.sql.DataSource"  maxActive="100"
              maxIdle="30" maxWait="10000" username="root" password="bdqn"
              driverClassName="com.mysql.jdbc.Driver"
              url="jdbc:mysql://127.0.0.1:3306/kgcnews"/>

代码分析：
1、Resource 代表一个资源，后面是一些属性。
2、name是该数据源的逻辑名称，将来程序里面要通过这个名称获得数据源，这个名称很重要，可以随便取，但是别取中文。
3、auth代表认证，这个不用管
4、type代表数据源类型
5、maxActive指的是连接池里面的最大数据库连接数
6、maxIdle指的是最大的空闲连接数
7、maxWait指的是最大的等待时间，也就是说连接池里面的连接都被别人占用了，你没得用的时候的最大等待时间。
上面几个之中记住type和name就行了。
8、username、password是连接数据库的账号密码（要改成自己的账密）
9、driverClassName是数据库驱动的名字
10、url是数据库的url地址

3.2获取连接

示例代码：

package cn.kgc.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

import cn.kgc.util.ConfigManager;

//数据库操作基类
public class BaseDao {
    // 获取数据连接
    Connection connection = null;
    PreparedStatement pstmt = null;
    ResultSet rs = null;
    
    // 获取数据库连接
    public boolean getConnection(){
        try {
            Class.forName(ConfigManager.getInstanse().getString("jdbc.driver"));
            String url = ConfigManager.getInstanse().getString("jdbc.connection.url");
            String username = ConfigManager.getInstanse().getString("jdbc.connection.user");
            String password = ConfigManager.getInstanse().getString("jdbc.connection.password");
            connection = DriverManager.getConnection(url, username, password);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            return false;
        } catch (SQLException e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }
    
   
    
    // 释放资源
    public boolean closeSource(){
        if (rs != null) {
            try {
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
                return false;
            }
        }
        if (pstmt != null) {
            try {
                pstmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
                return false;
            }
        }
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
                return false;
            }
        }
        return true;
    }
    
    // 增删改
    public int executeUpdate(String sql, Object[] params){
        int updateRows = 0;
        if (this.getConnection()) {
            try {
                pstmt = connection.prepareStatement(sql);
                // 填充占位符
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i+1, params[i]);
                }
                updateRows = pstmt.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return updateRows;
    }
    
    //查
    public ResultSet executeSQL(String sql, Object[] params){
        if (this.getConnection()) {
            try {
                pstmt = connection.prepareStatement(sql);
                // 填充占位符
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i+1, params[i]);
                }
                rs = pstmt.executeQuery();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return rs;
    }
    
    
    // 获取数据库连接
    public boolean getConnection2(){
        try {
            // 初始化一个上下文对象
            Context cxt = new InitialContext();
            // 获取与逻辑名称相关联的数据源对象
            // 这个地方一定要加上前缀：java:comp/env/
            DataSource ds = (DataSource)cxt.lookup("java:comp/env/jdbc/news");
            // 就可以通过数据源来获取数据库连接
            connection = ds.getConnection();
        } catch (NamingException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        
        // 
        return true;
    }
    
    // 测试通过数据源获取连接
    public ResultSet executeSQL2(String sql, Object[] params){
        if (this.getConnection2()) {
            try {
                pstmt = connection.prepareStatement(sql);
                // 填充占位符
                for (int i = 0; i < params.length; i++) {
                    pstmt.setObject(i+1, params[i]);
                }
                rs = pstmt.executeQuery();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return rs;
    }
}

以上代码中的getConnection2方法就是使用数据源来获取的连接。
注：
1、在写第二行代码的时候，后面的lookup方法需要参数，该参数就是配置tomcat的时候的name属性，但是要加上前缀："java:comp/env/jdbc/news。
2、lookup方法返回的是一个Object对象，需要强转为DataSource对象。
3、连接池是由容器来管理的，这个容器可以先理解为Tomcat服务器，所以要使用这种方法，必须先启动Tomcat服务器。同时这种方法不允许写完之后直接去main方法里面测试，要先打开服务器。

四、测试

4.1在BaseDao基类 中添加通过数据源获取连接的方法getConnection2，同时写一个新的查询的方法executeSQL2，在该查询方法中调用getConnection2。

4.2在接口中添加通过通过数据源获取连接的方法，以规范实现类的行为，具体代码如下：

package cn.kgc.dao;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Date;

public interface NewsDao {
    // 增加新闻信息
    public void addNews(int id,int categoryId,String title,String summary,String content,String author,Date createDate);
    // 删除特定新闻
    public void deleteNews(int id);
    // 修改特定新闻的标题
    public void updateNews(int id, String title);
    // 查询全部新闻信息
    public void getAllNews();
    // 查询特定的新闻id、标题
    public void getNewsByTitle(String title);
    
    // 通过数据源获取连接，然后进行数据库操作来查询新闻
    public void getAllNewsByDS();
}

4.3在实现类中定义一个新的查询的方法getAllNewsByDS，该方法调用父类BaseDao中的executeSQL2。

具体代码如下：

package cn.kgc.dao.implement;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Date;

import cn.kgc.dao.BaseDao;
import cn.kgc.dao.NewsDao;

// 使用PreparedStatement
public class NewsDaoImpl extends BaseDao implements NewsDao {

    // 增加新闻信息
    public void addNews(int id,int categoryId,String title,String summary,String content,String author,Date createDate){
        String sql = "INSERT INTO news_detail(id, categoryId, title, " +
                "summary,content,author, createDate) VALUES(?,?,?,?,?,?,?);";
        Object[] params = {id, categoryId, title, summary,content, author,createDate};
        int i = this.executeUpdate(sql, params);
        if (i > 0) {
            System.out.println("插入资源成功！");
        }
        this.closeSource();
    }
    // 删除特定新闻
    public void deleteNews(int id){
        String sql = "DELETE FROM news_detail WHERE id=?";
        Object[] params = {id};
        int i = this.executeUpdate(sql, params);
        if (i > 0){
            System.out.println("删除新闻信息成功");
        }
        this.closeSource();
    }
    // 修改特定新闻的标题
    public void updateNews(int id, String title){
        String sql = "UPDATE news_detail SET title=? WHERE id=?";
        Object[] params = {title,id};
        int i = this.executeUpdate(sql, params);
        if (i > 0){
            System.out.println("修改新闻信息成功");
        }
        this.closeSource();
    }
    // 查询全部新闻信息
    public void getAllNews(){
        String sql = "SELECT id, title, author,createDate FROM news_detail";
        Object[] params = {};
        ResultSet rs = this.executeSQL(sql,params);
        try {
            while(rs.next()){
                int id = rs.getInt("id");
                String newsTitle = rs.getString("title");
                String author = rs.getString("author");
                Timestamp createdate = rs.getTimestamp("createDate");
                System.out.println(id + " " + newsTitle + " " + author + " " + createdate);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        this.closeSource();
    }
    
    // 查询特定的新闻id、标题
    public void getNewsByTitle(String title){
        try {
            String sql = "SELECT id, title FROM news_detail where title=?";
            Object[] params = {title};
            ResultSet rs = this.executeSQL(sql,params);
            while(rs.next()){
                int id = rs.getInt("id");
                String newsTitle = rs.getString("title");
                System.out.println(id + " " + newsTitle);
            }
        }catch (SQLException e) {
            e.printStackTrace();
        } finally {
            this.closeSource();
        }
    }
    
    public static void main(String[] args) {
        NewsDao dao = new NewsDaoImpl();
        dao.getAllNewsByDS();
    }
    
    // 通过数据源获取的连接去执行查询
    public void getAllNewsByDS() {
         String sql = "SELECT id, title, author,createDate FROM news_detail";
            Object[] params = {};
            ResultSet rs = this.executeSQL2(sql,params);
            try {
                while(rs.next()){
                    int id = rs.getInt("id");
                    String newsTitle = rs.getString("title");
                    String author = rs.getString("author");
                    Timestamp createdate = rs.getTimestamp("createDate");
                    System.out.println(id + " " + newsTitle + " " + author + " " + createdate);
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            this.closeSource();
    }
}

4.4创建一个jsp页面，调用实现类中的getAllNewsByDS方法。

代码如下：

<%@page import="cn.kgc.dao.NewsDao"%>
<%@page import="cn.kgc.dao.implement.NewsDaoImpl"%>
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
    
    <title>My JSP 'testDataSource.jsp' starting page</title>
    
    <meta http-equiv="pragma" content="no-cache">
    <meta http-equiv="cache-control" content="no-cache">
    <meta http-equiv="expires" content="0">    
    <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
    <meta http-equiv="description" content="This is my page">
    <!--
    <link rel="stylesheet" type="text/css" href="styles.css">
    -->

  </head>
  
  <body>
    <%
        // 测试数据源配置是否成功，获取所有新闻信息
        NewsDao dao = new NewsDaoImpl();
        dao.getAllNewsByDS();
     %>
  </body>
</html>

4.5部署项目到服务器，开启服务器，用浏览器进行访问。结果如下：

image.png

可以看到结果有了。

五、在上述操作过程中的bug

5.1This kind of launch is configured to openthe debug perspective when it suspends

image.png

而且程序没有执行完。
原因：自己不小心设置了断点。
解决方法：
1、点YES
2、打开debug，在弹出来的debug视图左上角，有个变量 和 断点窗口Breakpoints 的窗口，打开breakpoints,取消其中的断点选择；
3、window-->show view 里面调出来这个窗口，断点窗口里面显示了在文件中加入的所有断点，删除这些断点都之后就不会有这个提示了 。

5.2org.apache.tomcat.dbcp.dbcp.SQLNestedException ： Access denied for user 'root' @ 'localhost' (using password: YES)

密码错误，原因是我在配置文件中把密码写错了。

5.3浏览器505：空值异常，找不到界面

org.apache.tomcat.dbcp.dbcp.SQLNestedException: Cannot create PoolableConnectionFactory (Unknown database 'news')

愿意：配置文件中的url写错了。
解决方法：正确书写配置文件中的url。

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

推荐阅读更多精彩内容

  • 关于Mongodb的全面总结
    关于Mongodb的全面总结 MongoDB的内部构造《MongoDB The Definitive Guide》...
    中v中阅读 31,893评论 2赞 89
  • 第一次坐飞机
    人的一声中有许多令人难忘的第一次，而让我记忆犹新的第一次是——坐飞机。 记得在二年级的暑假，我们...
    白鹤_2f44阅读 217评论 2赞 3
  • 秋天
    渐渐入秋了，我拖着自己漫无目的的灵魂生活在中国的最南边《海南》，这里四季如夏，除了夏天就是秋天，我生活了五年的地方...
    茜栀阅读 168评论 0赞 1