一万年太久，只争朝夕
What JDBC
上部
JDBC（Java DataBase Connectivity）Java 数据库连接，主要提供编写 Java 数据库应用程序的 API 支持
java.sql包中定义的常用的基本的 JDBC API：
类 DriverManager－管理一组 JDBC 驱动程序的基本服务 接口 Connection－获得与特定数据库的连接
接口 Statement－用于执行静态 SQL 语句并返回它所生成结果的对象
接口 ResultSet－表示数据库结果集的数据表，通常通过执行
查询数据库的语句生成 类 SQLException－有关数据库操作的异常
使用JDBC 访问数据库的前提条件
数据库的主机地址（ＩＰ地址）localhost 127.0.0.1 如果你访问的是别人的数据库，记得输入别人的ＩＰ
端口号：oracle 1521 ，MySql 3306， SqlServer 1433 因为我连得数据库是oracle，Ojdbc14.jar包，千万别忘了
数据的用户名/密码
JDBC核心API
Driver接口：驱动程序接口
Connection connect(String url, Properties info) 用于连接数据库的方法
可以使用驱动程序管理类获取这样的连接
DriverManager.getConnection(String url, String user, String password)
Connection 接口 :代表和数据库的连接
Statement createStatement() 创建Statement接口的对象
PreparedStatement prepareStatement(String sql) 创建PreparedStatement接口的对象
Statement接口 用于执行静态sql语句
int executeUpdate(String sql) 执行DDL和DML语句，如果不记得什么是DDL和DML，可以参考上一篇oracle基础
ResultSet executeQuery(String sql) 执行DQL语句，同理
PreparedStatement接口 ： 用于执行预编译的sql语句
int executeUpdate(String sql) 执行DDL和DML语句
ResultSet executeQuery(String sql) 执行DQL语句
ResultSet接口：表示数据库的结果集
boolean next() 将光标转移到下一行的位置
getXXX() 获取结果集中每列的值
很少用，了解
CallableStatement prepareCall(String sql)
CallableStatement接口 ：（了解）用于存储过程的SQL语句
下部
详解DriverManager类
用DriverManager加载驱动，，获得与数据库的连接，
驱动设备管理器进行连接
Driver driver = new oracle.jdbc.OracleDriver();
DriverManager.registerDriver(driver);
//推荐使用该方法
//驱动程序（只注册一次）
Class.forName("oracle.jdbc.driver.OracleDriver");
关于url 的写法
jdbc:oracle:thin:@localhost:1521:orcl
详解Connection 类
用于与数据库的连接，数据库与客户端的打交道都是由Connection方法来完成的，常用方法：
createStatement()：创建向数据库发送sql的statement对象。
prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
commit() ：提交事务。
rollback() ：回滚事务。
详解Statement 接口
Statement对象用于向数据库发送SQL语句， Statement对象常用方法：
executeQuery(String sql) ：用于向数据发送查询语句。
executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
详解ResultSet 接口
ResultSet用于代表Sql语句的执行结果。开始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。
ResultSet既然获得数据库执行后的对象，提供了获取数据的get 方法
获取指定类型的数据，例如：
getString(int index)
getString(String columnName)
ResultSet还提供了对结果集进行滚动的方法：
next()：移动到下一行
关于释放资源：
切记一点，一定要记得关闭，还有就是先开的后关，后开的先关。
详解部分参照API文档：
代码展示
目录结构：
package Jdbc; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; /**
* statement 用于执行静态sql 但是实际开发很少用， PreparedStatement ：用于执行预编译的sql语句
* @author Administrator
*
*/
public class FirstJdbc { private static String user = "scott";
private static String password = "tiger";
private static String url = "jdbc:oracle:thin:@localhost:1521:orcl"; public static void main(String[] args) throws ClassNotFoundException, SQLException { // 加载驱动 Class.forName("oracle.jdbc.driver.OracleDriver"); //获取数据库连接 Connection conn = DriverManager.getConnection(url, user, password); System.out.println(conn);
// 下面是输出 conn 的结果 ；证明数据库连接成功
//oracle.jdbc.driver.T4CConnection@5afec107 //准备sql语句
String sql = "select * from userinfo"; //获取用于向数据库发送sql语句的statement
Statement stmt = conn.createStatement();
//获取数据库连接对象
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()){ System.out.println("uname="+rs.getString("uname"));
System.out.println("upass="+rs.getString("upass"));
}
//关闭连接，释放资源(遵循原则 先开喉管)
rs.close();
stmt.close();
conn.close();
} }
package Jdbc; import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; public class SecondJdbc { /**
* PreparedStatement ：用于执行预编译的sql语句，动态拼接sql ?作为占位符, 可以有效的防止Sql注入的问题
*
*/
private static Connection conn = null;
private static String user = "scott";
private static String password = "tiger";
private static String url = "jdbc:oracle:thin:@localhost:1521:orcl"; public static void main(String[] args) throws ClassNotFoundException, SQLException { //为了使页面使页面干净，在这里处理的异常都向外抛出
// TODO Auto-generated method stub // 加载驱动 Class.forName("oracle.jdbc.driver.OracleDriver"); //获取数据库连接 Connection conn = DriverManager.getConnection(url, user, password); System.out.println(conn);
// 下面是输出 conn 的结果 ；证明数据库连接成功
//oracle.jdbc.driver.T4CConnection@5afec107 //准备sql语句
String sql = "insert into userinfo(uname,upass)values (?,?)"; //获取用于向数据库发送sql语句的preparedStatement
PreparedStatement stmt = conn.prepareStatement(sql);
//设置参数 注意这里的参数设置从1开始，不像数组等下标从0开始
stmt.setString(1,"张作霖");
stmt.setString(2, "123");
//获取数据库连接对象
int count = stmt.executeUpdate();
//事务处理
if(count>0){
conn.commit();
}else{
//这里的rollback肯定执行不了，因为上面执行的sql(insert)用户名是可以重复的，用重名的可能性
conn.rollback();
}
System.out.println("影响了"+count+"行");
//关闭连接，释放资源(遵循原则 先开喉管) stmt.close();
conn.close();
} }
package Jdbc; 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; /**
* 为了日后开发方便，不用频繁的获取驱动，获取连接，
* 定义url ,数据库，用户名 等参数，所以自己封装Jdbc工具类
*
*/
public class JdbcUtils { //定义url 数据库用户名和密码
private static Connection conn = null;
private static PreparedStatement pst;
private static String user = "scott";
private static String password = "tiger";
private static String url = "jdbc:oracle:thin:@localhost:1521:orcl"; private JdbcUtils() {
} //单例模式
public static Connection getcConnection() {
if (conn == null) {
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
conn = DriverManager.getConnection(url, user, password);
System.out.println("获取connection连接成功"); } catch (ClassNotFoundException e) {
System.out.println("加载驱动失败");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("连接数据库失败");
e.printStackTrace();
}
}
return conn; }
//之前用作数据库连接池连接，自己封装，如果没有用请忽略
/* public static Connection getPoolConnection(){
if(conn==null){
try {
Context context = new InitialContext();
DataSource ds =
(DataSource) context.lookup("java:/comp/env/jdbc/oracleds");
conn = ds.getConnection();
System.out.println("连接池数据库成功！");
} catch (NamingException e) {
System.out.println("连接池数据库失败！");
e.printStackTrace();
} catch (SQLException e) {
System.out.println("连接池数据库失败！");
e.printStackTrace();
}
} return conn;
}*/ //关闭连接
public static void close() { try {
if (conn != null) {
conn.close();
conn = null;
}
if (pst != null) {
pst.close();
pst = null;
}
System.out.println("关闭成功");
} catch (SQLException e) {
System.out.println("关闭失败");
e.printStackTrace();
} } // 执行更新操作
public static int executeUpdate(String sql, Object[] obj) {
int count = 0; try {
pst = conn.prepareStatement(sql);
if (obj != null) {
for (int i = 0; i < obj.length; i++) {
pst.setObject(i + 1, obj[i]);
}
}
count = pst.executeUpdate();
} catch (SQLException e) {
count = 0;
e.printStackTrace();
} return count;
}
//执行查询操作，带参数
public static ResultSet executeQuery(String sql, Object obj[]) {
ResultSet rs = null;
try {
pst = conn.prepareStatement(sql);
if (obj != null) {
for (int i = 0; i < obj.length; i++) {
pst.setObject(i + 1, obj[i]);
}
}
rs = pst.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} return rs;
}
//执行查询操作.无参数
public static ResultSet executeQuery(String sql) {
ResultSet rs = null; try {
pst = conn.prepareStatement(sql);
rs = pst.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} return rs;
}
//开始事物
public static void beginTransation() {
try {
conn.setAutoCommit(false);
System.out.println("开始事物");
} catch (SQLException e) {
System.out.println("开始事物失败");
e.printStackTrace();
} }
//提交事物
public static void commit() {
try {
conn.commit();
System.out.println("提交事物");
} catch (SQLException e) {
System.out.println("提交事物失败");
e.printStackTrace();
} }
//回滚事物
public static void rollback(){
try {
conn.rollback();
System.out.println("回滚事务");
} catch (SQLException e) {
System.out.println("回滚事务失败");
e.printStackTrace();
}
}
}
数据库表
select * from userinfo;
第一次代码FirstJdbc 执行的结果：
第二次代码SecondJdbc 执行的结果:
