首页 / JAVA / JAVA jdbc(数据库连接池)学习笔记（一）

JAVA jdbc(数据库连接池)学习笔记（一）

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了JAVA jdbc(数据库连接池)学习笔记（一），小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含11373字，纯文字阅读大概需要17分钟。

内容图文

1.JDBC的含义...

JDBC想必学过JAVA的就不会陌生，JDBC到底是什么呢？其实就是由JAVA的一些类和接口构成的API，保存在java.sql和javax.sql..包中的一些API...

2.使用JDBC的原因...

那么为什么要使用，这个想必大家也是更为了解了，一个应用程序如果不和数据库进行连接，那这根本就不算是个应用程序，那么应用程序是不能直接对数据库进行操作的，那么就需要一个辅助工具去连接数据库，从而操作数据库...那这个辅助的工具就是JDBC了，这个仅限于JAVA应用程序...其实总体的规模就是这样：应用程序——>JDBC——>（mysql driver——>mysql）

JDBC——>（oracle driver——>oracle）

JDBC——>（DB2 driver——>db2）就是这么简单的事...多余的就不罗嗦了...

3.如何使用JDBC...

如何使用JDBC,才是真正的重点...使用JDBC分为几个步骤...

我这里只对链接mysql进行讲解...

i.首先注册驱动

Class.forName("com.mysql.Driver");//这种方式是最好的,不会对具体驱动产生依赖...
DriverManager.registerDriver(com.mysql.jdbc.Driver);//会产生两个相同的驱动,并会对具体驱动产生依赖...
System.setProperty("jdbc.drivers","driver1:driver2");//基本不常用,所以可以不用记,一般就使用第一种就行了...

ii.建立连接

Connection conn = DriverManager.getConnection(url, user, password);

iii.创建执行SQL语句...

Statement st = conn.createStatement();  
st.executeQuery(sql);  
PreparedStatement  
String sql = "select * from table_name where col_name=?";  
PreparedStatement ps = conn.preparedStatement(sql);  
ps.setString(1, "col_value");  
ps.executeQuery();

iv.处理执行结果...

    ResultSet rs = statement.executeQuery(sql);  
    While(rs.next()){  
    rs.getString(“col_name”);  
    rs.getInt(“col_name”);  
    }

v.释放资源...

释放资源这是必须的，使用close()进行关闭...由于数据库的资源是非常珍贵的，因此只要我们不去使用资源的时候，一定要记得释放...

先来个例子：还是例子更加的好理解...

import java.sql.*;//1.引包是必须的...

public class JDBC_1_1 {
    static final String JDBC_DRIVER="com.mysql.jdbc.Driver";
    static final String DB_URL ="jdbc:mysql://localhost:3306/emp";//这个链接是我本机的数据库emp...emp里有个表格叫employees....
    /*表格的信息
     *create table employees
     *(
     *    id int not null,
     *    first varchar(255) not null,
     *    last varchar(255) not null,
     *    age int not null
     *);
     */
    static final String USER="root";//登陆数据库时的用户名...
    static final String PAS="49681888";登陆时的密码...
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        Connection conn=null;
        Statement stmt=null;//
        try {
            //2.注册JDBC驱动程序...
            Class.forName("com.mysql.jdbc.Driver");
            //3.打开一个链接...
            System.out.println("Connection database....");
            conn=DriverManager.getConnection(DB_URL,USER,PAS);

            //4.执行一个操作...
            System.out.println("Creating statement");
            stmt=conn.createStatement();
//          String sql;
//          sql="select id,first,last,age from employees"; 这个是查询操作...
//          ResultSet rs=stmt.executeQuery(sql);
            String sql_1="insert into employees " + "values (7, ‘z‘, ‘yh‘, 20)";//插入操作...
            stmt.executeUpdate(sql_1); 
            
            
            5.提取数据...
//          while(rs.next()){  //rs用来保存sql执行后的结果...
//              int id=rs.getInt("id");
//              int age=rs.getInt("age");
//              String first=rs.getString("first");
//              String last=rs.getString("last");   
//              System.out.println(id+" "+age+" "+first+" "+last);
//          }
            6.清理环境
//          rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            System.out.println("no class");
        }finally{
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(conn!=null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
        System.out.println("Goodbye");
    }

}

其他操作，比如说删除啊，更改啊，这个模式基本都差不多...就不进行解释了...

注意：如果我们使用JDBC的时候，一定要检查检查自己的的jdk的lib文件夹下有没有mysql-connector-java-5.1.18-bin.jar这个压缩文件..如果没有，那么程序运行时会出现错误...解决方法就是我们下一个mysql-connector-java-5.1.18-bin.jar这个文件，几k而已，下载完毕之后直接拷贝到jdk的lib文件夹下即可..

如果使用的是eclipse，我们还要导入这个文件...右击我们建立的项目文件，然后点击build path——>configure build path,弹出对话框以后，点击Libraries——>Add External JARs...找到这个mysql-connector-java-5.1.18-bin.jar文件导入，然后就可以了...

4.使用JDBC实现CURD操作...什么是CURD操作呢？其实就是对数据进行更新，删除等操作...

这里我们采用分层操作...这个代码很长...

首先是User实体...

package JDBC_3;
import java.util.Date;
class User{            //user类..
    private int id;
    private String name;
    private Date birthday;
    private float money;
    public User(){
    }
    public User(int id,String name,Date birthday,float money){
        this.id=id;
        this.name=name;
        this.birthday=birthday;
        this.money=money;
    }
    public int getid(){
        return id;
    }
     public void setId(int id) {  
            this.id = id;  
        }  
        public String getName() {  
            return name;  
        }  
        public void setName(String name) {  
            this.name = name;  
        }  
        public Date getBirthday() {  
            return birthday;  
        }  
        public void setBirthday(Date birthday) {  
            this.birthday = birthday;  
        }  
        public float getMoney() {  
            return money;  
        }  
        public void setMoney(float money) {  
            this.money = money;  
        }  
      
        @Override  
        public String toString(){  
            return "[id="+id+",name="+name+",birthday="+birthday+",money="+money+"]";  
        }  
}

接着是我们的Dao层，就是接口...

package JDBC_3;

interface UserDao{
    public abstract void addUser(User user);
    public abstract User getUserById(int userid);
    public abstract int update(User user);
    public abstract int delete(User user);
}

然后是实现接口的类...

package JDBC_3;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Date;
import java.sql.ResultSet;
/*
 * JDBC实现crud操作
 * crud操作就是对数据进行增删改查...
 * */
public class JDBC_3_1_server implements UserDao{
    static final String DB_URL="jdbc:mysql://localhost:3306/emp";
    static final String user_1="root";
    static final String pas="49681888";
    static{
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    public void addUser(User user){
        Connection cn=null;
        PreparedStatement ps=null;
        try {
            cn=DriverManager.getConnection(DB_URL,user_1,pas);
            String sql="insert into userr values(2,‘clearlove‘,‘1995-01-26‘,200)";
            //String sql="insert into userr values(?,?,?,?)";这句话是传参数是未知的，需要我们进行获取...
            ps=cn.prepareStatement(sql);
            //这四个函数就是为了获取我们插入的信息...上面采用了直接在sql里写入我们要插入的数据，其实我们也可以在主函数里进行传参...见下面主函数...
//            ps.setInt(1,user.getid());
//            ps.setString(2,user.getName());
//            ps.setDate(3, new Date(user.getBirthday().getTime()));
//            ps.setFloat(4, 20);
            int count=ps.executeUpdate();
            System.out.println("添加的记录数"+count);
            ps.close();
            cn.close();
            
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            
        }finally{
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }finally{
                    if(cn!=null){
                        try {
                            cn.close();
                        } catch (SQLException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
        
    }
    public User getUserById(int userid){
        Connection cn=null;
        PreparedStatement ps=null;
        ResultSet rs=null;
        try {
            cn=DriverManager.getConnection(DB_URL,user_1,pas);
            String sql="select * from userr where id=1";
            //导入sql语句...
            ps=cn.prepareStatement(sql);
            //保存执行sql语句后的结果对象...
            rs=ps.executeQuery();
            ps.close();
            cn.close();
            rs.close();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            if(ps!=null){
                try {
                    ps.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(rs!=null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if(cn!=null){
                try {
                    cn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
        return null;
    }
    public int update(User user){
        Connection cn=null;
        PreparedStatement ps=null;
        try {
            cn=DriverManager.getConnection(DB_URL,user_1,pas);
            String sql="update userr set name=‘clearlove‘,birthday=‘1994-12-19‘,money=60 where id=1";
            ps=cn.prepareStatement(sql);
            int count=ps.executeUpdate();
            return count;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                cn.close();
                ps.close();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return 0;
    }
    public int delete(User user){
        Connection cn=null;
        PreparedStatement ps=null;
        try {
            cn=DriverManager.getConnection(DB_URL,user_1,pas);
            String sql="delete from userr where id=1";
            ps=cn.prepareStatement(sql);
            int count=-1;
            count=ps.executeUpdate();
            return count;
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                cn.close();
                ps.close();
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }        
        }
        return 0;
    }
}

接着是服务层...

package JDBC_3;
class userserves {
    
    private UserDao userDao;
    public userserves(){
        userDao =DaoFactory.getInstance().createUserDao();//通过工厂实例化一个例子。。
        System.out.println("userDao "+userDao);
    }
    
    public void regist(User user){
        if(user==null){
            System.out.println("注册表信息无效...");
        }else{
            userDao.addUser(user);
        }
    }
    
    public User query(int userId){  
        User user = userDao.getUserById(userId);  
        if(user == null){  
            System.out.println("查询结果为空!!");  
        }else{  
            System.out.println(user.getid()+"\t"+user.getName()+"\t"+user.getBirthday()+"\t"+user.getMoney());  
        }  
        return userDao.getUserById(userId);  
    }  
    
    public void update(User user){
        if(user.getid()<0){
            System.out.println("用户id无效,重新输入");
        }else{
            userDao.update(user);
        }
    }
    
    public void delete(User user){
        if(user.getid()<0){
            System.out.println("用户id无效,重新输入");
        }else{
            userDao.delete(user);
        }
    }
}

定义一个工厂模式来实例化对象UserDao。。。

package JDBC_3;
class DaoFactory{
    private static UserDao userdao=null;
    private static DaoFactory instance= new DaoFactory();
    private DaoFactory(){
        try {
            userdao=(UserDao)Class.forName("JDBC_3.JDBC_3_1_server").newInstance();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } 
    }
    public static DaoFactory getInstance(){
        return instance;
    }
    public UserDao createUserDao(){
        return userdao;
    }
}

最后是测试类...

package JDBC_3;
import java.sql.Date;
public class JDBC_3_1_ceshi {

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        userserves userse=new userserves();
        System.out.println("添加用户");
        userse.regist(new User()); //这句话我们也可以这样
        //userse.regist(new User(1,"clearlove","1995-01-26",300));这样写我们可以固定传参...但是上面的一些代码就要进行修改了...
    }

}

上面的代码估计是有点长，但是也没关系...一名优秀的程序员这点代码对于我们来说算什么呢？其实上面的例子是很好理解的...都是一些基本的东西...

我们除了上述那种方式可以对类名进行加载，我们还可以使用proprties...是一种很灵活的方式...

private DaoFactory(){  
        /** 
         * 通过读取属性文件来动态的加载Dao层类 
         */  
        Properties prop = new Properties();  
        try{  
            FileInputStream fis = new FileInputStream("src/com/weijia/domain/daoconfig.properties");  
            prop.load(fis);  
            String className = prop.getProperty("userDaoClass");  
            Class<?> clazz = Class.forName(className);  
            userDao = (UserDao)clazz.newInstance();  
            fis.close();  
        }catch(Exception e){  
        }  
    }

这里的数据库就是一个简单的数据库...

create table userr
( 
    id int not null,
    name varchar(255) not null,
    birthday Date,
    money float not null
);

JAVA jdbc(数据库连接池)学习笔记（一）

标签：

本文系统来源：http://www.cnblogs.com/RGogoing/p/4515521.html

内容总结

以上是互联网集市为您收集整理的JAVA jdbc(数据库连接池)学习笔记（一）全部内容，希望文章能够帮你解决JAVA jdbc(数据库连接池)学习笔记（一）所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/447328.html

来源：【匿名】

【上一篇】完整全面的Java资源库（包括构建、操作、代码分析、编译器、数据库、社区等等）【下一篇】JAVA/JSP学习系列之五

更多 ►

【JAVA jdbc(数据库连接池)学习笔记（一）】教程文章相关的互联网学习教程文章

java 数据库连接【代码】

JDBC基本用法jdbc.driverClass=com.microsoft.sqlserver.jdbc.SQLServerDriver jdbc.url=jdbc:sqlserver://127.0.0.1:1433;DatabaseName=test jdbc.username=root jdbc.password=rootpublicstatic Connection getConnection() throws IOException, ClassNotFoundException, SQLException {Properties props = new Properties();props.load(new FileInputStream("jdbc.properties"));Class.forName(props.getProperty("jdbc.driverC...

Java数据库连接——JDBC调用存储过程,事务管理和高级应用【代码】【图】

阅读目录一、JDBC常用的API深入详解及存储过程的调用1、存储过程（Stored Procedure）的介绍2、JDBC调用无参存储过程3、JDBC调用含输入参数存储过程4、JDBC调用含输出参数存储过程二、JDBC的事务管理1、JDBC实现事务管理2、通过代码实现事物的管理三、数据库连接池（dbcp、c3p0）1、dbcp使用步骤2、c3p0使用步骤3、连接池总结四、JDBC的替代产品（Hibernate、Mybatis）1、Commons-dbutils　2、Hibernate简介3、Mybatis简介一、JDBC...

java关于jdbc后台数据库连接

关于数据库连接，想接触后台的同学肯定都会先想到这个，对于这块基本是个定死的东西，基本都是按部就班，当然如果你有兴趣可以研究研究这么才能跟方便快捷的连接，下面的是关于本人的一些代码连接基本只要你加载了驱动包，那么改掉密码用户名就可以使用public class DBConnection {private static final String DBDRIVER="com.mysql.jdbc.Driver";//驱动加载private static final String DBURL="jdbc:mysql://localhost:3306/...

Java获取数据库连接

Driver：package xuezaipiao;import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.Driver; import java.sql.SQLException; import java.util.Properties;public class getDabseConnection {public static void main(String[] args){System.out.println(getConnection());}private static Connection getConnection(){//1.获取本地配...

Java mysql数据库连接Demo1【代码】

publicclass MysqlUtil {/*** 链接数据库*//*** 方法一：* 加载驱动的方法不止一种，但这种最常用*/publicstatic Connection getConnectionOne(String database,String username,String password){try {Class.forName("com.mysql.jdbc.Driver");Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/"+database,username,password);return connection;}catch(Exception e){e.printStackTrace();}ret...

数据库连接JDBC和数据库连接池C3P0自定义的java封装类

import java.sql.*;2 3 import utils.GlobalConstant;4 5 public class JDBCUtil {6 7 private JDBCUtil() {8 9 }10 11 /**12 * 获取JDBC的数据库连接13 */14 public static Connection getConnection() {15 Connection conn = null;16 try {17 Class.forName(GlobalConstant.CONNECTION_DRIVER);18 conn = DriverManager.getConnection(GlobalConstant.CONNEC...

《Java程序设计》第16周周五：数据库连接与随机数的使用【代码】【图】

第一部分：实验项目项目二：数据库初步。目的：了解Java连接数据库的步骤与方法，以及MySQL数据库的安装与使用。目标：（1）在机房安装上MySQL数据库。成功安装 MySQL数据库（2）创建数据表 student(id varchar(12),name varchar(20), success int, failure int )，导入相应的数据到文件中。success 与 failure的默认值为1。创建student表连接数据库代码import java.sql.*;public class JDBCTest {public static void main(St...

Java培训-Oracle学习【1】数据库连接【代码】

1.连接ORACLE数据库：连接放在同一个类的主方法中package com.softeem.jdbc;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;public class JDBCTest { public static void main(String[] args) { Connection conn=null; Statement st=null; ResultSet rs=null; try { ...

去哪网实习总结：怎样配置数据库连接（JavaWeb）【代码】

大四狗最合适不过了。。。）在公司里，开发系统往往使用开发环境，真实环境只有在系统开发好了之后，才可以上线使用，那么数据库连接如何配置呢？答案是，使用.properties文件配置。直接上代码： DBConfig.properties：#development environment server_oa = *** port_oa = *** user_oa = *** pass_oa = *** dbname_oa = <span style="font-family: Arial, Helvetica, sans-serif;">oadb</span>#real environment #server_oa = <s...

Java数据库连接泄漏应对办法-基于Weblogic服务器【图】

JNDI数据源步骤2（可选）：可配置最大数据连接数量步骤3：连接泄漏自动关闭点击图标，展开后，设置当存在连接泄漏时，WEBLogic10自动将自动关闭。通过属性【非活动连接超时】设置超时秒数。0代表禁用，设置大于1。例如：设置30秒后，对于泄漏的连接自动关闭。此处设置后，可在weblogic10日志中查看到连接自动关闭的记录及连接泄漏点的日志。见日志小节描述。监控连接泄漏设置连接泄漏概要文件钩选”概要文件连接泄...

java与mysql数据库连接测试

package com.java; import java.sql.DriverManager; import com.mysql.jdbc.Connection;import com.mysql.jdbc.ResultSet;import com.mysql.jdbc.Statement; public class TestMySql{ public static void main(String[] args){ try { Class.forName("com.mysql.jdbc.Driver"); //加载MYSQL JDBC驱动程序 //Class.forName("org.gjt.mm.mysql.Driver"); System.out.println("Success loading Mysql Dri...

JAVA WEB中如何让数据库连接对开发人员完全透明？【代码】

org.smart4j.chapter2.util;import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.util.Properties; import org.slf4j.Logger; import org.slf4j.LoggerFactory;/*** Created by sahara on 2016/3/15.*/ public final class PropsUtil {private static final Logger LOGGER=LoggerFactory.getLogger(PropsUtil.class);public static Properties loadProps(String fileName...

Java数据库连接——JDBC基础知识（操作数据库：增删改查）【代码】【图】

Java语言访问数据库的一种规范,是一套API。 JDBC (Java Database Connectivity) API，即Java数据库编程接口，是一组标准的Java语言中的接口和类，使用这些接口和类，Java客户端程序可以访问各种不同类型的数据库。比如建立数据库连接、执行SQL语句进行数据的存取操作。JDBC代表Java数据库连接。 JDBC库中所包含的API任务通常与数据库使用：连接到数据库创建SQL或MySQL语句在数据库中执行SQL或MySQL查询查看和修改记录比如：二、JDB...

jdbc java数据库连接 3）Statement接口【代码】

接口：用于执行静态的sql语句|- int executeUpdate(String sql) ：执行静态的更新sql语句（DDL，DML）|- ResultSet executeQuery(String sql) ：执行的静态的查询sql语句（DQL）|-PreparedStatement接口（Statement接口的子类）：用于执行预编译sql语句|- int executeUpdate() ：执行预编译的更新sql语句（DDL，DML）|-ResultSet executeQuery() ：执行预编译的查询sql语句（DQL）代码：（用DDL语句来举例，其实DDL.DML.D...

jdbc java数据库连接 2）jdbc接口核心的API

APIjava.sql.* 和 javax.sql.*（java2.0以后更新的扩展） |- Driver接口：表示java驱动程序接口。所有的具体的数据库厂商要来实现此接口。|- connect(url, properties): 连接数据库的方法。　url: 连接数据库的URL URL语法： jdbc协议:数据库子协议://主机:端口/数据库user：数据库的用户名password：数据库用户密码 |- DriverManager类：驱动管理器类，用于管理所有注册的驱动程序|-registerDriver(driver) : 注册驱动...

首页 / JAVA / JAVA jdbc(数据库连接池)学习笔记（一）

JAVA jdbc(数据库连接池)学习笔记（一）

内容导读

内容图文

内容总结

内容备注

内容手机端

【JAVA jdbc(数据库连接池)学习笔记（一）】教程文章相关的互联网学习教程文章

java 数据库连接【代码】

Java数据库连接——JDBC调用存储过程,事务管理和高级应用【代码】【图】

java关于jdbc后台数据库连接

Java获取数据库连接

Java mysql数据库连接Demo1【代码】

数据库连接JDBC和数据库连接池C3P0自定义的java封装类

《Java程序设计》第16周周五：数据库连接与随机数的使用【代码】【图】

Java培训-Oracle学习【1】数据库连接【代码】

去哪网实习总结：怎样配置数据库连接（JavaWeb）【代码】

Java数据库连接泄漏应对办法-基于Weblogic服务器【图】

java与mysql数据库连接测试

JAVA WEB中如何让数据库连接对开发人员完全透明？【代码】

Java数据库连接——JDBC基础知识（操作数据库：增删改查）【代码】【图】

jdbc java数据库连接 3）Statement接口【代码】

jdbc java数据库连接 2）jdbc接口核心的API

数据库连接 - 相关标签

JAVA - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程