1.1如何获取JDBC驱动程序
驱动程序由数据库提供商提供下载。
MySQL的驱动下载地址:http://dev.mysql.com/downloads/
1.2如何在Java Project项目应用中添加数据库驱动jar
(1)把mysql-connector-java-5.1.36-bin.jar拷贝到项目中一个目录中。
(2)添加到项目的类路径下在驱动jar上右键-->Build Path-->Add to Build Path。
注意:如果是Dynamic Web Project(动态的web项目)话,则是把驱动jar放到WebContent(有的开发工具叫Webroot)目录中的WEB-INF目录中的lib目录下即可。
加载并注册驱动:
加载驱动,把驱动类加载到内存
注册驱动,把驱动类的对象交给DriverManager管理,用于后面创建连接等使用。
2.1 Driver接口
Java.SQL.Driver 接口是所有 JDBC 驱动程序需要实现的接口。这个接口是提供给数据库厂商使用的,不同数据库厂商提供不同的实现。
MySQL:com.mysql.jdbc.Driver
SQLServer:com.microsoft.sqlserver.jdbc.SQLServerDriver
oracle:oracle.jdbc.driver.OracleDriver
2.2编写加载与注册驱动的代码
1)直接创建Driver接口的实现类对象
例如:
Driver driver = new com.mysql.jdbc.Driver();
//因为与mysql驱动包中的类发生直接依赖,所以这样可移植性不够好
2)DriverManager 类的 registerDriver()
在实际开发中,程序中不直接去访问实现了 Driver 接口的类,而是由驱动程序管理器类(java.sql.DriverManager)去调用这些Driver实现。
DriverManager 类是驱动程序管理器类,负责管理驱动程序。
通常不用显式调用 DriverManager 类的 registerDriver() 方法来注册驱动程序类的实例。
//DriverManager.registerDriver()方式注册驱动,还是依赖 DriverManager.registerDriver(new com.mysql.jdbc.Driver());
3)Class.forName()或ClassLoader对象.loadClass()
因为 Driver 接口的驱动程序类都包含了静态代码块,在这个静态代码块中,会调用 DriverManager.registerDriver() 方法来注册自身的一个实例,所以可以换一种方式来加载驱动。(即只要想办法让驱动类的这段静态代码块执行即可注册驱动类,而要让这段静态代码块执行,只要让该类被类加载器加载即可)。
调用 Class 类的静态方法 forName(),向其传递要加载的 JDBC 驱动的类名
//1、通过反射,加载与注册驱动类,解耦合(不直接依赖) Class.forName("com.mysql.jdbc.Driver");
//2、通过类加载器加载驱动类,解耦合(不直接依赖) ClassLoader.getSystemClassLoader().loadClass("com.mysql.jdbc.Driver");
4)服务提供者框架(例如:JDBC的驱动程序)自动注册(有版本要求)
符合JDBC 4.0规范的驱动程序包含了一个文件META-INF/services/java.sql.Driver,在这个文件中提供了JDBC驱动实现的类名。例如:mysql-connector-java-5.1.40-bin.jar文件中就可以找到java.sql.Driver文件,用文本编辑器打开文件就可以看到:com.mysql.jdbc.Driver类。
JVM的服务提供者框架在启动应用时就会注册服务,例如:MySQL的JDBC驱动就会被注册,而原代码中的Class.forName("com.mysql.jdbc.Driver")仍然可以存在,但是不会起作用。
但是注意mysql-connector-java-5.0.8-bin.jar版本的jar中没有,如下
3、获取数据库链接可以通过 DriverManager 类建立到数据库的连接Connection:
DriverManager 试图从已注册的 JDBC 驱动程序集中选择一个适当的驱动程序。
public static Connection getConnection(String url)
public static Connection getConnection(String url,String user, String password)
public static Connection getConnection(String url,Properties info)[I1]
3.1 JDBC URL
JDBC URL 用于标识一个被注册的驱动程序,驱动程序管理器通过这个 URL 选择正确的驱动程序,从而建立到数据库的连接。
JDBC URL的标准由三部分组成,各部分间用冒号分隔。
jdbc:<子协议>:<子名称>
协议:JDBC URL中的协议总是jdbc
子协议:子协议用于标识一个数据库驱动程序
子名称:一种标识数据库的方法。子名称可以依不同的子协议而变化,用子名称的目的是为了定位数据库提供足够的信息
例如:
MySQL的连接URL编写方式:
jdbc:mysql://主机名称:mysql服务端口号/数据库名称?参数=值&参数=值
jdbc:mysql://localhost:3306/testdb
jdbc:mysql://localhost:3306/testdb?useUnicode=true&characterEncoding=utf8[I2]
jdbc:mysql://localhost:3306/testdb?user=root&password=123456
Oracle9i:
jdbc:oracle:thin:@主机名称:oracle服务端口号:数据库名称
jdbc:oracle:thin:@localhost:1521:testdb
SQLServer
jdbc:sqlserver://主机名称:sqlserver服务端口号:DatabaseName=数据库名称
jdbc:sqlserver://localhost:1433:DatabaseName=testdb
//1、加载与注册驱动 Class.forName("com.mysql.jdbc.Driver");
//2、获取数据库连接 String url = "jdbc:mysql://localhost:3306/test"; Connection conn = DriverManager.getConnection(url, "root", "root");
//硬编码
3.2 jdbc.properties
在src下建立文件jdbc.properties,当然也可以是其他名字,只不过这里为了见名知意取这个名
通常至少应该包括 "user" 和 "password" 属性
#key=valuedriver=com.mysql.jdbc.Driverurl=jdbc:mysql://localhost:3306/testuser=rootpassword=root
public static void main(String[] args) throws Exception {//预先加载配置文件jdbc.properties,把配置信息封装到Properties对象中Properties pro = new Properties();//ClassLoader只能加载类路径下的资源文件//如果不是类路径下,只能使用FileInputStreampro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"));//1、加载与注册驱动Class.forName(pro.getProperty("driver"));//2、获取数据库连接// Connection conn = DriverManager.getConnection(pro.getProperty("url"), pro);Connection conn = DriverManager.getConnection(pro.getProperty("url"), pro.getProperty("user"),pro.getProperty("password"));System.out.println(conn);}//解决了硬编码的问题
数据库连接被用于向数据库服务器发送命令和 SQL 语句,并接受数据库服务器返回的结果。
其实一个数据库连接就是一个Socket连接。
在 java.sql 包中有 3 个接口分别定义了对数据库的调用的不同方式:
Statement:用于执行静态 SQL 语句并返回它所生成结果的对象。
PrepatedStatement:SQL 语句被预编译并存储在此对象中,然后可以使用此对象多次高效地执行该语句。
CallableStatement:用于执行 SQL 存储过程
4.1 Statement
通过调用 Connection 对象的 createStatement() 方法创建该对象
该对象用于执行静态的 SQL 语句,并且返回执行结果
Statement 接口中定义了下列方法用于执行 SQL 语句:
int excuteUpdate(String sql):执行更新操作INSERT、UPDATE、DELETE
ResultSet excuteQuery(String sql):执行查询操作SELECT
4.2 ResultSet
通过调用 Statement 对象的 excuteQuery() 方法创建该对象
ResultSet 对象以逻辑表格的形式封装了执行数据库操作的结果集,ResultSet 接口由数据库厂商实现
ResultSet 对象维护了一个指向当前数据行的游标,初始的时候,游标在第一行之前,可以通过 ResultSet 对象的 next() 方法移动到下一行
ResultSet 接口的常用方法:
boolean next()
getXxx(String columnLabel):columnLabel使用 SQL AS 子句指定的列标签。如果未指定 SQL AS 子句,则标签是列名称
getXxx(int index) :索引从1开始
…
java类型与SQL类型的对应关系
Connection、Statement、ResultSet都是应用程序和数据库服务器的连接资源,使用后一定要关闭,可以在finally中关闭
未关闭后果:
@Testpublic void testConnection4()throws Exception{Properties pro = new Properties();pro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"));String url = pro.getProperty("url");//my.ini中max_connections=10for (int i = 0; i < 15; i ) {Connection conn = DriverManager.getConnection(url,pro);System.out.println(conn);//没有关闭,资源一直没有释放}}
package com.atguigu.statement;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.Statement;import org.junit.Test;public class TestStatement {@Testpublic void testAdd()throws Exception{String sql = "INSERT INTO dept(dname,description) VALUES('财务部','负责发钱工作')";String url = "jdbc:mysql://localhost:3306/1221db";String user = "root";String password = "123456";Connection conn = DriverManager.getConnection(url, user, password);Statement st = conn.createStatement();int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法if(len>0){System.out.println("添加成功");}else{System.out.println("添加失败");}st.close();conn.close();}@Testpublic void testUpdate()throws Exception{String sql = "UPDATE dept SET description = '负责发工资、社保、公积金工作' WHERe dname ='财务部'";String url = "jdbc:mysql://localhost:3306/1221db";String user = "root";String password = "123456";Connection conn = DriverManager.getConnection(url, user, password);Statement st = conn.createStatement();int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法if(len>0){System.out.println("修改成功");}else{System.out.println("修改失败");}st.close();conn.close();}@Testpublic void testDelete()throws Exception{String sql = "DELETE FROM dept WHERe did =2";String url = "jdbc:mysql://localhost:3306/1221db";String user = "root";String password = "123456";Connection conn = DriverManager.getConnection(url, user, password);Statement st = conn.createStatement();int len = st.executeUpdate(sql);//把insert,update,delete都用这个方法if(len>0){System.out.println("删除成功");}else{System.out.println("删除失败");}st.close();conn.close();}@Testpublic void testSelect()throws Exception{String sql = "SELECT * FROM dept";String url = "jdbc:mysql://localhost:3306/1221db";String user = "root";String password = "123456";Connection conn = DriverManager.getConnection(url, user, password);Statement st = conn.createStatement();ResultSet rs = st.executeQuery(sql);//select语句用query方法while(rs.next()){//是否有下一行//取这一行的单元格int id = rs.getInt(1);String name = rs.getString(2);String desc = rs.getString(3);System.out.println(id "\t" name "\t" desc);}rs.close();st.close();conn.close();}@Testpublic void testSelect2()throws Exception{String sql = "SELECT did,dname FROM dept";String url = "jdbc:mysql://localhost:3306/1221db";String user = "root";String password = "123456";Connection conn = DriverManager.getConnection(url, user, password);Statement st = conn.createStatement();ResultSet rs = st.executeQuery(sql);//select语句用query方法while(rs.next()){//是否有下一行//取这一行的单元格int id = rs.getInt("did");String name = rs.getString("dname");System.out.println(id "\t" name);}rs.close();st.close();conn.close();}}
Properties info通常至少应该包括 "user" 和 "password" 属性
如果JDBC程序与服务器端的字符集不一致,会导致乱码,那么可以通过参数指定服务器端的字符集
相关阅读:
java编程技术JDBC
如何使用JDBC API操作数据库
数据库连接池之DBCP数据源
java技术教程IOC和DI
java技术Docker容器