jdbc的基本操作（API的使用与操作详解）
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=value
driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test
user=root
password=root
public static void main(String[] args) throws Exception {
//预先加载配置文件jdbc.properties，把配置信息封装到Properties对象中
Properties pro = new Properties();
//ClassLoader只能加载类路径下的资源文件
//如果不是类路径下，只能使用FileInputStream
pro.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中关闭
未关闭后果：
@Test
public void testConnection4()throws Exception{
Properties pro = new Properties();
pro.load(ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"));
String url = pro.getProperty("url");
//my.ini中max_connections=10
for (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;
/*
* 网络编程：tcp
*
* 服务器端：
* 1、Serversocket server = new ServerSocket(3306);
* 2、Socket socket = server.accept();
* 3、InputStream input = socket.getInputStream();//接收sql，客户端传过来的
* 4、在服务器执行sql
* 5、把结果给客户端
*
* 客户端：
* 1、Socket socket = new Socket(服务器的IP地址，3306);
* 2、传sql
* 3、OutputStream out = socket.getOutputStream();
* 4、out.write(sql);
* 5、接收结果
* 6、断开连接 out.close();socket.close();
*/
public class TestStatement {
@Test
public 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();
}
@Test
public 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();
}
@Test
public 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();
}
@Test
public 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();
}
@Test
public 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容器
,免责声明：本文仅代表文章作者的个人观点，与本站无关。其原创性、真实性以及文中陈述文字和内容未经本站证实，对本文以及其中全部或者部分内容文字的真实性、完整性和原创性本站不作任何保证或承诺，请读者仅作参考，并自行核实相关内容。文章投诉邮箱：anhduc.ph@yahoo.com
