MySQL 是一个开放源码的小型关联式数据库管理系统, 开发者为瑞典 MySQL AB 公司 MySQL 被广泛地应用在 Internet 上的中小型网站中由于其体积小速度快总体拥有成本低, 尤其是开放源码这一特点, 许多中小型网站为了降低网站总体拥有成本而选择了 MySQL 作为网站数据库
JDBC 是用于执行 SQL 语句的一类 Java API, 通过 JDBC 使得我们可以直接使用 Java 编程来对关系数据库进行操作通过封装, 可以使开发人员使用纯 Java API 完成 SQL 的执行
前言: 什么是 JDBC
Java 数据库连接,(Java Database Connectivity, 简称 JDBC)是 Java 语言中用来规范客户端程序如何来访问数据库的应用程序接口, 提供了诸如查询和更新数据库中数据的方法 JDBC 也是 Sun Microsystems 的商标它 JDBC 是面向关系型数据库的
简单地说, 就是用于执行 SQL 语句的一类 Java API, 通过 JDBC 使得我们可以直接使用 Java 编程来对关系数据库进行操作通过封装, 可以使开发人员使用纯 Java API 完成 SQL 的执行
一准备工作(一):MySQL 安装配置和基础学习
使用 JDBC 操作数据库之前, 首先你需要有一个数据库这里提供了 3 个链接供读者自学, 如果曾有过 SQL 语言的使用经历(包括在学校中的课堂学习), 前两个链接足以上手
Mysql 下载安装部署与图形化详细操作教程:/article/16/0802/238029.html
建议边看入门教程, 边练习, 在练习 insertupdateselectdelete 等基本操作的同时, 将后面要用的表建好
下图是我接下来用于演示的数据库的表
二准备工作(二): 下载数据库对应的 jar 包并导入
使用 JDBC 需要在工程中导入对应的 jar 包数据库与 JDBC 包的对应关系可以参考各种数据库对应的 jar 包驱动类名和 URL 格式在 Eclipse 下的导入方法:
在工程的图标上右击, 选择 Properties, 在 Java Bulid Path 中选择 Add External JARs, 选择下载并解压后获得的 jar 包
如果对 MySQL 进行操作, 这时下面的 import 就不会报错了:
- import com.mysql.jdbc.Connection;
- import com.mysql.jdbc.PreparedStatement;
除此以外, 还需要 JDBC 的包, 直接 import 即可
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.SQLException;
三 JDBC 基本操作
为了简单起见, 与数据库相关的操作命令参数都被硬编码了有兴趣的读者可以对这些进行探索, 降低数据与操作的耦合性
先看具体代码并实践, 本文第五部分对用到的 API 稍作了研究
下面的所有方法和数据成员都在 public class JDBCOperation 内部
(1)定义记录的类(可选)
这样做主要是为了便于操作和接口定义, 是非必须的
- static class Student {
- private String Id;
- private String Name;
- private String Sex;
- private String Age;
- Student(String Name, String Sex, String Age) {
- this.Id = null; //default
- this.Name = Name;
- this.Sex = Sex;
- this.Age = Age;
- }
- public String getId() {
- return Id;
- }
- public void setId(String Id) {
- this.Id = Id;
- }
- public String getName() {
- return Name;
- }
- public void setName(String Name) {
- this.Name = Name;
- }
- public String getSex() {
- return Sex;
- }
- public void setSex(String Sex) {
- this.Sex = Sex;
- }
- public String getAge() {
- return Age;
- }
- public void setage(String Age) {
- this.Age = Age;
- }
- }
(2)连接的获取
在操作前必须先获取与数据库的连接
- private static Connection getConn() {
- String driver = "com.mysql.jdbc.Driver";
- String url = "jdbc:mysql://localhost:3306/samp_db";
- String username = "root";
- String password = "";
- Connection conn = null;
- try {
- Class.forName(driver); //classLoader, 加载对应驱动
- conn = (Connection) DriverManager.getConnection(url, username, password);
- } catch(ClassNotFoundException e) {
- e.printStackTrace();
- } catch(SQLException e) {
- e.printStackTrace();
- }
- return conn;
- }
- (3)insert
- private static int insert(Student student) {
- Connection conn = getConn();
- int i = 0;
- String sql = "insert into students (Name,Sex,Age) values(?,?,?)";
- PreparedStatement pstmt;
- try {
- pstmt = (PreparedStatement) conn.prepareStatement(sql);
- pstmt.setString(1, student.getName());
- pstmt.setString(2, student.getSex());
- pstmt.setString(3, student.getAge());
- i = pstmt.executeUpdate();
- pstmt.close();
- conn.close();
- } catch(SQLException e) {
- e.printStackTrace();
- }
- return i;
- }
- (4)update
- private static int update(Student student) {
- Connection conn = getConn();
- int i = 0;
- String sql = "update students set Age='" + student.getAge() + "'where Name='" + student.getName() + "'";
- PreparedStatement pstmt;
- try {
- pstmt = (PreparedStatement) conn.prepareStatement(sql);
- i = pstmt.executeUpdate();
- System.out.println("resutl:" + i);
- pstmt.close();
- conn.close();
- } catch(SQLException e) {
- e.printStackTrace();
- }
- return i;
- }
- (5)select
以 select * from XXX 为例
- private static Integer getAll() {
- Connection conn = getConn();
- String sql = "select * from students";
- PreparedStatement pstmt;
- try {
- pstmt = (PreparedStatement) conn.prepareStatement(sql);
- ResultSet rs = pstmt.executeQuery();
- int col = rs.getMetaData().getColumnCount();
- System.out.println("============================");
- while (rs.next()) {
- for (int i = 1; i <= col; i++) {
- System.out.print(rs.getString(i) + "\t");
- if ((i == 2) && (rs.getString(i).length() < 8)) {
- System.out.print("\t");
- }
- }
- System.out.println("");
- }
- System.out.println("============================");
- } catch(SQLException e) {
- e.printStackTrace();
- }
- return null;
- } (6) delete private static int delete(String name) {
- Connection conn = getConn();
- int i = 0;
- String sql = "delete from students where Name='" + name + "'";
- PreparedStatement pstmt;
- try {
- pstmt = (PreparedStatement) conn.prepareStatement(sql);
- i = pstmt.executeUpdate();
- System.out.println("resutl:" + i);
- pstmt.close();
- conn.close();
- } catch(SQLException e) {
- e.printStackTrace();
- }
- return i;
- }
四测试
在测试前, 需要在系统中打开对应数据库的服务 MySQL 在 Windows 下的启动命令为 net start mysql
测试代码
- public static void main(String args[]) {
- JDBCOperation.getAll();
- JDBCOperation.insert(new Student("Achilles", "Male", "14"));
- JDBCOperation.getAll();
- JDBCOperation.update(new Student("Bean", "", "7"));
- JDBCOperation.delete("Achilles");
- JDBCOperation.getAll();
- }
Eclipse 中的输出
- ============================
- 1 Ender male 8
- 2 Bean male 6
- 3 Petra fema 9
- 4 Peter male 9
- 5 _Graff male 40
- 6 GOD fema 255
- ============================
- ============================
- 1 Ender male 8
- 2 Bean male 6
- 3 Petra fema 9
- 4 Peter male 9
- 5 _Graff male 40
- 6 GOD fema 255
- 7 Achilles Male 14
- ============================
- resutl: 1
- resutl: 1
- ============================
- 1 Ender male 8
- 2 Bean male 7
- 3 Petra fema 9
- 4 Peter male 9
- 5 _Graff male 40
- 6 GOD fema 255
- ============================
五代码分析
在上述对数据库进行增删改查的过程中, 可以发现其共性部分, 即通用的流程:
(1)创建 Connection 对象 SQL 查询命令字符串;
(2)对 Connection 对象传入 SQL 查询命令, 获得 PreparedStatement 对象;
(3)对 PreparedStatement 对象执行 executeUpdate()或 executeQurey()获得结果;
(4)先后关闭 PreparedStatement 对象和 Connection 对象
可见, 使用 JDBC 时, 最常打交道的是 ConnectionPreparedStatement 这两个类, 以及 select 中的 ResultSet 类
- Connection
- java.sql
接口 Connection
所有超级接口: Wrapper
- --------------------------------------------------------------------------------
- public interface Connectionextends Wrapper
与特定数据库的连接 (会话) 在连接上下文中执行 SQL 语句并返回结果
Connection 对象的数据库能够提供描述其表所支持的 SQL 语法存储过程此连接功能等等的信息此信息是使用 getMetaData 方法获得的
- PreparedStatemnt
- java.sql
接口 PreparedStatement
所有超级接口: Statement, Wrapper 所有已知子接口: CallableStatement
- --------------------------------------------------------------------------------
- public interface PreparedStatementextends Statement
表示预编译的 SQL 语句的对象
SQL 语句被预编译并存储在 PreparedStatement 对象中然后可以使用此对象多次高效地执行该语句
常用方法
boolean execute()
在此 PreparedStatement 对象中执行 SQL 语句, 该语句可以是任何种类的 SQL 语句
ResultSet executeQuery()
在此 PreparedStatement 对象中执行 SQL 查询, 并返回该查询生成的 ResultSet 对象
int executeUpdate()
在此 PreparedStatement 对象中执行 SQL 语句, 该语句必须是一个 SQL 数据操作语言 (Data Manipulation Language,DML) 语句, 比如 INSERTUPDATE 或 DELETE 语句; 或者是无返回内容的 SQL 语句, 比如 DDL 语句
- ResultSet
- java.sql
接口 ResultSet
所有超级接口: Wrapper 所有已知子接口: CachedRowSet, FilteredRowSet, JdbcRowSet, JoinRowSet,RowSet,SyncResolver, webRowSet
- --------------------------------------------------------------------------------
- public interface ResultSetextends Wrapper
表示数据库结果集的数据表, 通常通过执行查询数据库的语句生成
六思考问题
1. 每次 SQL 操作都需要建立和关闭连接, 这势必会消耗大量的资源开销, 如何避免?
分析: 可以采用连接池, 对连接进行统一维护, 不必每次都建立和关闭事实上这是很多对 JDBC 进行封装的工具所采用的
2.Java 代码中, 传入的数据格式与数据库定义不同怎么办? 如把 Java 的 String 对象赋值给数据库的 tinyint 属性
分析: 在执行 SQL 语句时, 数据库会尝试进行转换根据我的实验, 如果用内容为纯字母的 String 对象传入 tinyint 的 age 属性时, 会被转化成 0 具体转化规则应该和数据库有关
来源: http://www.phperz.com/article/18/0217/358877.html