JAVA通过JDBC连接并操作MySQL数据库
JDBC(Java Data Base Connectivity,java数据库连接)是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用Java语言编写的类和接口组成。
首先我们在MySQL数据库中创建一个table,以供测试使用。
建表语句如下:
- CREATE TABLE student(
- ID VARCHAR(5),
- name VARCHAR(20),
- age int(3),
- FM VARCHAR(1),
- PRIMARY KEY(ID)
- )
建表结果如下图所示:
数据库建好之后,我们就可以开始编程连接并操作数据库了。步骤如下:
1、 加载JDBC驱动程序
1、 加载JDBC驱动程序
在连接数据库之前,首先要加载想要连接的数据库的驱动到JVM(Java虚拟机),这通过java.lang.Class类的静态方法forName(String className)实现。 示例代码如下:
- try{
- Class.forName("com.mysql.jdbc.Driver");
- }catch(ClassNotFoundException e){
- System.out.println("No jdbc driver");
- e.printStackTrace();
- }
成功加载之后,会将Driver类的实例注册到DriverManager类中。
2、提供JDBC连接的URL
连接URL定义了连接数据库时的协议、子协议、数据源标识,
其
书写格式:协议:子协议:数据源标识
协议:在JDBC中总是以jdbc开始
协议:在JDBC中总是以jdbc开始
子协议:是桥连接的驱动程序或是数据库管理系统名称
数据源标识:标记找到数据库来源的地址与连接端口
- String url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&characterEncoding=utf-8";
- String username = "root";
- String password = "snow";
useUnicode=tru
e
表示使用Unicode字符集
characterEncoding=utf-8
表示使用utf-8字符编码方式
3、
创建数据库的连接
(1)、要连接数据库,需要向java.sql.DriverManager请求并获得Connection对象,该对象就代表一个数据库的连接。
(2)、使用DriverManager的getConnectin(String url , String username , String password )方法传入指定的欲连接的数据库的路径、数据库的用户名和密码来获得。
- try{
- Connection con = DriverManager.getConnection(url,username,password);
- }catch(SQLException e){
- System.out.println("Database connect failure!");
- e.printStackTrace();
- }
4、创建一个Statement
要执行SQL语句,必须获得java.sql.Statement实例,Statement实例分为以下3种类型:
(1)、执行静态SQL语句。通常通过Statement实例实现
(2)、执行动态SQL语句。通常通过PreparedStatement实例实现
(3)、执行数据库存储过程。通常通过CallableStatement实例实现
具体实现方式:
- try{
- Statement stmt = con.createStatement();
- }catch(SQLException e){
- System.out.println("Statement create failure!");
- e.printStackTrace();
- }
5、执行SQL语句
Statement接口提供了三种执行SQL语句的方法:executeQuery 、executeUpdate和execute
(1)、ResultSet executeQuery(String sqlString):执行查询数据库的SQL语句,返回一个结果集(ResultSet)对象。
(2)、int executeUpdate(String sqlString):用于执行INSERT、UPDATE或DELETE语句以及SQL DDL语句,如:CREATE TABLE和DROP TABLE等
(3)、execute(sqlString):用于执行返回多个结果集、多个更新计数或二者组合的语句。
实现方式示例:
- ResultSet rs = stmt.executeQuery("SELECT * FROM ...");
- int rows = stmt.executeUpdate("INSERT INTO ...");
- boolean flag = stmt.execute(String sql);
6、处理结果
此处分为两种情况:
(1)、执行更新返回的是本次操作影响到的记录数
(2)、执行查询返回的结果是一个ResultSet对象
ResultSet包含符合SQL查询语句中条件的所有行,并且它通过一套get方法提供了对这些行中数据的访问。
使用结果集ResultSet对象的访问方法访问数据实例:
- while(rs.next()){
- String qname = rs.getString("name");
- String qage = rs.getString(3); //此种方法比较高效,列是从左向右编号的,编号从1开始
- System.out.println(qname + " " + qage);
- }
7、关闭JDBC对象
操作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声明顺序相反:
(1)、关闭记录集
(2)、关闭声明
(3)、关闭连接对象
实现范例
- try{
- if(rs != null){
- rs.close();
- }
- if(stmt != null){
- stmt.close();
- }
- if(con != null){
- con.close();
- }
- }catch(SQLException e){
- e.printStackTrace();
- }
总结,注意上面每一个操作都需要捕获SQLException,这个比较讨厌。将整个流程衔接起来如下面示例程序所示:
- import java.lang.Class;
- import java.sql.Connection;
- import java.sql.DriverManager;
- import java.sql.ResultSet;
- import java.sql.Statement;
- import java.sql.PreparedStatement;
- import java.sql.ResultSet;
- import java.sql.SQLException;
- public class MySQLtest{
- public static void main(String [] args){
- String[] ID = { "2008", "2009", "2008", "2012", "2015","2015" };
- String[] name = { "Wang", "Hui", "Wan", "Yuan", "Yuan", "Yang"};
- int[] age = { 16, 18, 20, 18, 22, 21 };
- String[] FM = {"F", "F", "M", "M", "M", "F"};
- String url="jdbc:mysql://localhost:3306/mysql?useUnicode=true&characterEncoding=utf-8";
- String username = "root";
- String password = "snow";
- String sql = "INSERT INTO class.student(ID,name,age,FM)VALUES(?,?,?,?)";
- String querysql = "SELECT * FROM class.student WHERE name LIKE 'Yuan';";
- try{
- Class.forName("com.mysql.jdbc.Driver");
- }catch(ClassNotFoundException e)
- {
- System.out.println("JDBC驱动加载失败");
- e.printStackTrace();
- }
- try{
- Connection con = DriverManager.getConnection(url,username,password); //MySQL连接对象
- Statement stmt = con.createStatement();
- PreparedStatement prest = con.prepareStatement(sql, ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
- for(int i=0; i<ID.length; i++){
- prest.setString(1, ID[i]);
- prest.setString(2, name[i]);
- prest.setInt(3, age[i]);
- prest.setString(4,FM[i]);
- prest.addBatch();
- }
- prest.executeBatch();
- ResultSet rs = stmt.executeQuery(querysql);
- while(rs.next()){
- String qname = rs.getString("name");
- String qage = rs.getString(3);
- System.out.println(qname + " " + qage);
- }
- int rows = stmt.executeUpdate("DELETE FROM class.student;");
- System.out.println(rows);
- if(rs != null){
- rs.close();
- }
- if(stmt != null){
- stmt.close();
- }
- if(con != null){
- con.close();
- }
- }catch(SQLException e){
- e.printStackTrace();
- }
- }
- }
我是创建的maven项目,需要添加mysql-connector-java-5.1.35.jar包,以下为maven中添加的dependency
- <dependency>
- <groupId>mysql</groupId>
- <artifactId>mysql-connector-java</artifactId>
- <version>5.1.35</version>
- </dependency>
本文参考博客链接:http://www.cnblogs.com/hongten/archive/2011/03/29/1998311.html
转载自:https://blog.csdn.net/wanghuiqi2008/article/details/46238457#0-qzone-1-67024-d020d2d2a4e8d1a374a433f596ad1440