提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档
本节讲的是如何Java如何连接MySQL数据库,进行增删改查操作
1>加载驱动(每一个数据库厂商都有一个jar包,jar包中有一个驱动类) 2>创建一个连接对象,连接数据库 3>准备一个操作句柄对象(Statement对象),用来执行SQL语句的 4>开始写SQL语句,然后使用Statement对象调用方法来执行SQL语句 5>【该步骤是可选的】如果执行的是一个DQL语句(查询语句),就有结果集返回(ResultSet对象),就需要获取结果集中的数据 6>释放资源(关闭ResultSet对象、关闭Statement对象、关闭Connection对象) 一般释放JDBC的相关资源时,在finally语句块中释放,需要按照“从小到大”的顺序释放: ResultSet对象 - Statement对象 - Connection对象
jar包可在官网自行下载。
接下来直接上代码
import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class DBUtil { /* * 数据库连接属性 */ //驱动类名 private static final String DRIVER_NAME="com.mysql.jdbc.Driver"; /* url(【MySQL的连接格式】jdbc:mysql://ip地址:端口号/要用的数据库) 这里url中加了2个参数:useUnicode和characterEncoding useUnicode 使用unicode编码 characterEncoding 使用utf8的编码格式进行与数据库交互 */ private static final String URL="jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8"; //username private static final String USERNAME="root"; //password private static final String PASSWORD="root"; private static Connection conn=null; private static Statement stmt=null; private static ResultSet rs=null; static{ //1>加载驱动(数据库产商提供的驱动) //下面这行代码会去寻找“com.mysql.jdbc.Driver”这个类是否存在,如果存在则创建它的对象 //如果“com.mysql.jdbc.Driver”这个类不存在,则会抛出ClassNotFoundException try { Class.forName(DRIVER_NAME); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 打开连接 * @throws SQLException */ public static void open() throws SQLException{ //2>创建jdbc连接 //java.sql.SQLException: Access denied for user 'root'@'localhost' (using password: YES) //The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. //连接mysql中test数据库 //getConnection(连接地址, 用户名, 密码) conn=DriverManager.getConnection(URL, USERNAME, PASSWORD); } /** * 执行DQL * @throws SQLException */ public static ResultSet executeDQL(String sql) throws SQLException{ //3>创建Statement对象 stmt=conn.createStatement(); //4>执行DML语句 rs=stmt.executeQuery(sql); return rs;//返回是rs对象的引用地址 } /** * 执行DML * @throws SQLException */ public static int executeDML(String sql) throws SQLException{ //3>创建Statement对象 stmt=conn.createStatement(); //4>执行DML语句 int result=stmt.executeUpdate(sql); return result; } /** * 释放资源 */ public static void close(){ try { if (rs!=null) { rs.close(); } if (stmt!=null) { stmt.close(); } if (conn!=null) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }JDBC的几大步骤已经列出来了,并且整合成了一个类,调用该类中的不同方法可以实现不同的功能。