jdbc是一组能够执行sql语句的api
由于传统的数据库操作方式需要程序员掌握各个不同的数据库的api，极其不便
因此java定义了jdbc这一标准的接口和类，为程序员操作数据库提供了统一的方式
jdbc的操作方式比较单一，由五个流程组成：
1.通过数据库厂商提供的jdbc类库向drivermanager注册数据库驱动
2.使用drivermanager提供的getconnection()方法连接到数据库
3.通过数据库的连接对象的createstatement方法建立sql语句对象
4.执行sql语句，并将结果集合返回到resultset中
5.使用while循环读取结果
6.关闭数据库资源
下面来看看具体操作mysql数据库的方法
准备工作
首先我们需要建立一个数据库和一张简单的表
mysql> create database person;
query ok, 1 row affected (0.00 sec)
mysql> use person;
database changed
mysql> create table student(
-> id int,
-> name varchar(20),
-> birth year
-> ) default charset=utf8;
query ok, 0 rows affected (0.10 sec)
然后往里面插入几条数据
mysql> insert into student values
-> (1,'张三',1990),
-> (2,'李四',1991),
-> (3,'王五',1992);
query ok, 3 rows affected (0.02 sec)
records: 3 duplicates: 0 warnings: 0
这样一张简单的表就建好了
mysql> select * from student;
+------+--------+-------+
| id | name | birth |
+------+--------+-------+
| 1 | 张三 | 1990 |
| 2 | 李四 | 1991 |
| 3 | 王五 | 1992 |
+------+--------+-------+
rows in set (0.00 sec)
接下来，去mysql官网下载数据库连接器这个包
其中这个包里面含有一份文档，里面列举了基本的使用方法，可以参考
我们的操作也是按照这份文档中的内容进行，然后最主要的地方就是导入这个jar包
为了操作方便，这里使用eclipse来导入
右键项目-->构件路径-->添加外部归档，添加好了之后如下所示
现在我们正式开始使用java来操作mysql数据库
jdbc操作实例1：最简单的查询操作
import java.sql.*;
public class demo {
//为了代码紧凑性，暂时抛出所有异常
public static void main(string[] args) throws exception {
//注册数据库驱动
class.forname(com.mysql.jdbc.driver);
//建立数据库连接
//参数一：jdbc：mysql//地址：端口/数据库,参数二：用户名，参数三：密码
connection conn = drivermanager.getconnection
(jdbc:mysql://localhost:3306/person,root,admin);
//创建sql语句
statement st = conn.createstatement();
//执行语句，返回结果
resultset rt = st.executequery(show tables);
//循环取出结果
while(rt.next()) {
//获取字段
system.out.println(rt.getstring(tables_in_person));
}
//关闭资源，最先打开的最后关
rt.close();
st.close();
conn.close();
}
}
运行结果：student
如此便可执行show tables语句查询出当前数据库含有多少张表
其中rt.getstring()方法是获取字段，这点需要注意
关闭资源的方式也与以往相反
不过，上面的操作方式灵活性不大，并且不严谨
实例2：优化的查询操作
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.resultset;
import java.sql.sqlexception;
import java.sql.statement;
public class demo {
public static void main(string[] args) {
string url = jdbc:mysql://localhost:3306/person;
string user = root;
string pwd = admin;
string sql = select * from student;
connection conn = null;
statement st = null;
resultset rs = null;
try {
class.forname(com.mysql.jdbc.driver);
conn = drivermanager.getconnection(url,user,pwd);
st = conn.createstatement();
//执行查询语句，另外也可以用execute()，代表执行任何sql语句
rs = st.executequery(sql);
while(rs.next()) {
system.out.println(rs.getobject(1) + +
rs.getobject(2) + + rs.getint(birth));
}
//分别捕获异常
} catch (classnotfoundexception e) {
e.printstacktrace();
} catch (sqlexception e) {
e.printstacktrace();
} finally {
try {
//判断资源是否存在
if(rs != null) {
rs.close();
//显示的设置为空，提示gc回收
rs = null;
}
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
}
运行结果：
这里把异常给分别捕获了，并且相关的字符串全部用变量定义
需要注意下循环取出数据里面的getint()方法，此处必须知道类型和字段才能取出
如果不知道可以使用getobject(1)取出第一列，getobject(2)取出第二列，以此类推
实例3：自定义变量插入到数据库
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.sqlexception;
import java.sql.statement;
public class demo {
public static void main(string[] args) {
//参数检查
if (args.length != 3) {
system.out.println(参数形式不对);
system.exit(0);
}
string id = args[0];
string name = args[1];
string birth = args[2];
string sql = insert into student values( + id + ,' + name +
', + ' + birth + ');
system.out.println(sql);
string url = jdbc:mysql://localhost:3306/person;
string user = root;
string pwd = admin;
connection conn = null;
statement st = null;
try {
class.forname(com.mysql.jdbc.driver);
conn = drivermanager.getconnection(url,user,pwd);
st = conn.createstatement();
//注意，此处是excuteupdate()方法执行
st.executeupdate(sql);
//分别捕获异常
} catch (classnotfoundexception e) {
e.printstacktrace();
} catch (sqlexception e) {
e.printstacktrace();
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
}
运行结果：
这里运行需要设置自变量，窗口中右键-->运行方式-->运行配置
然后在自变量里面写4 susan 1993，我没有写中文，因为产生乱码，目前还不清楚原因
需要注意的是，执行插入的sql语句比较难写，最好是打印出sql语句用以检查
实例4：preparedstatement应用
从上面的demo可以看到，插入数据的时候，sql操作相当不便
这里可以使用preparedstatement对象来简化sql语句的建立
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.preparedstatement;
import java.sql.sqlexception;
public class demo {
public static void main(string[] args) {
if (args.length != 3) {
system.out.println(参数形式不对);
system.exit(0);
}
string id = args[0];
string name = args[1];
string birth = args[2];
string url = jdbc:mysql://localhost:3306/person;
string user = root;
string pwd = admin;
connection conn = null;
//声明preparedstatement对象的引用
preparedstatement pst = null;
try {
class.forname(com.mysql.jdbc.driver);
conn = drivermanager.getconnection(url,user,pwd);
//使用？代替变量
pst = conn.preparestatement(insert into student values (?,?,?));
//给指定参数的位置设定变量
pst.setstring(1, id);
pst.setstring(2, name);
pst.setstring(3, birth);
pst.executeupdate();
} catch (classnotfoundexception e) {
e.printstacktrace();
} catch (sqlexception e) {
e.printstacktrace();
} finally {
try {
if(pst != null) {
pst.close();
pst = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
}
运行结果：
实例5：batch批处理
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.sqlexception;
import java.sql.statement;
public class demo {
public static void main(string[] args) {
string url = jdbc:mysql://localhost:3306/person;
string user = root;
string pwd = admin;
connection conn = null;
statement st = null;
try {
class.forname(com.mysql.jdbc.driver);
conn = drivermanager.getconnection(url,user,pwd);
st = conn.createstatement();
//添加批处理
st.addbatch(insert into student values(6,'jerry','1995'));
st.addbatch(insert into student values(7,'greg','1996'));
st.addbatch(insert into student values(8,'ryan','1997'));
//执行批处理
st.executebatch();
} catch (classnotfoundexception e) {
e.printstacktrace();
} catch (sqlexception e) {
e.printstacktrace();
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
}
运行结果：
批处理比较简单，只需先建立statement对象，然后逐个添加批处理即可
最后使用executebatch()方法执行批处理
此外，preparedstatement对象也可以使用批处理
preparedstatement ps = conn.preparestatement(insert into student values(?,?,?));
ps.setint(1,8);
ps.setstring(2,gg);
ps.setstring(3,1996);
ps.addbatch();
ps.executebatch();
实例6：transaction事务处理
事务处理是要求sql以单元的形式更新数据库，要求其确保一致性
如银行的转账业务，一方转出后，另一方则增加
如果出现异常，那么所有的操作则会回滚
import java.sql.connection;
import java.sql.drivermanager;
import java.sql.sqlexception;
import java.sql.statement;
public class demo {
public static void main(string[] args) {
string url = jdbc:mysql://localhost:3306/person;
string user = root;
string pwd = admin;
connection conn = null;
statement st = null;
try {
class.forname(com.mysql.jdbc.driver);
conn = drivermanager.getconnection(url,user,pwd);
//取消自动提交
conn.setautocommit(false);
st = conn.createstatement();
st.addbatch(insert into student values(6,'jerry','1995'));
st.addbatch(insert into student values(7,'greg','1996'));
st.addbatch(insert into student values(8,'ryan','1997'));
st.executebatch();
//提交后设置自动提交
conn.commit();
conn.setautocommit(true);
} catch (classnotfoundexception e) {
e.printstacktrace();
} catch (sqlexception e) {
e.printstacktrace();
if(conn != null) {
try {
//出现异常则回滚操作，然后设置自动提交
conn.rollback();
conn.setautocommit(true);
} catch (sqlexception e1) {
e1.printstacktrace();
}
}
} finally {
try {
if(st != null) {
st.close();
st = null;
}
if(conn != null) {
conn.close();
conn = null;
}
} catch (sqlexception e) {
e.printstacktrace();
}
}
}
}
运行结果：
bitscn.com