环境
- MySQL 5.5 版本
- eclipse
- MySQL 连接驱动 mysql-connector-java-5.1.18-bin.jar
mysql8.0之前的版本与之后的版本使用的jar包是不同的，在使用时也有一定的区别。这里，我的 MySQL 版本为 5.5。
准备工作
将 jar 包添加到项目中，右键项目，如下，选择Configure Build Path...
将刚才下载好的 jar 包添加进去即可
增删查改操作
- 首先，建立一个数据库模板 DBConfig.java
注意：要提前建立一个数据库，然后在JDBC_URL中填写你自己的数据库名称
package test;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;/*** 数据库连接和关闭工具类* @author ruochen* @version 1.0*/
public class DBConfig {/** 定义数据库驱动类名称 */private static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";/** 数据库连接地址 */private static final String JDBC_URL = "jdbc:mysql://127.0.0.1:3306/JavaDB?characterEncoding=utf8";/** 数据库用户名 */private static final String JDBC_USERNAME = "root";/** 数据库密码 */private static final String JDBC_PASSWORD = "root";/** 数据库连接对象 */private static Connection conn = null;/*** 获得链接* @return*/public static Connection getConnection() {try {try {// 加载驱动程序Class.forName(JDBC_DRIVER);System.out.println("加载成功");} catch (java.lang.ClassNotFoundException e) {System.out.println("ForName: " + e.getMessage());}conn = DriverManager.getConnection(JDBC_URL, JDBC_USERNAME, JDBC_PASSWORD);} catch (Exception e) {e.printStackTrace();}return conn;}public static void closeConnection(ResultSet rs, Statement ps, Connection conn) {try {if (null != rs) {rs.close();}if (null != ps) {ps.close();}if (null != conn) {conn.close();}} catch (Exception e) {System.out.println("Close connection error");e.printStackTrace();}}
}- 建表操作 CreateTest.jav
package test;import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;/*** JDBC链接数据库，创建数据表 * @author ruochen* @version 1.0*/
public class CreateTest {public static void main(String[] args) {Connection conn = DBConfig.getConnection();try {Statement st = conn.createStatement();ResultSet re = conn.getMetaData().getTables(null, null, "student", null);if (re.next()) {System.out.println("表已经存在");} else {// 建表语句String sql = "create table student ( "+ "id char(10),"+ "name char(16),"+ "score integer" + ")";st.executeUpdate(sql);System.out.println("创建成功");}DBConfig.closeConnection(re, st, conn);} catch (SQLException e) {System.out.println("SQLException: " + e.getMessage());}}}
加载成功
创建成功 
插入操作 InsertTest.java
package test;import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;/*** 数据表中插入数据 * @author ruochen* @version 1.0*/
public class InsertTest {public static void main(String[] args) {Connection conn = DBConfig.getConnection();try {Statement st = conn.createStatement();String r1 = "insert into student values('0001', '小王', 80)";String r2 = "insert into student values('0002', '小李', 82)";String r3 = "insert into student values('0003', '小张', 90)";st.executeUpdate(r1);st.executeUpdate(r2);st.executeUpdate(r3);System.out.println("插入成功");DBConfig.closeConnection(null, st, conn);} catch (SQLException e) {e.printStackTrace();}}
}
加载成功
插入成功
更新操作 UpdateTest.java
package test;import java.sql.Connection;
import java.sql.PreparedStatement;/*** 更新数据库操作 * @author ruochen* @version 1.0*/
public class UpdateTest {public static void main(String[] args) {Connection conn = DBConfig.getConnection();String[] id = {"0002", "0003"};int[] score = {70, 60};PreparedStatement ps;try {ps = conn.prepareStatement("Update student set score=? where id=?");int i = 0, idlen = id.length;do {ps.setInt(1, score[i]);ps.setString(2, id[i]);ps.executeUpdate();System.out.println("修改成功");++i;} while (i < idlen);DBConfig.closeConnection(null, ps, conn);} catch (Exception e) {e.printStackTrace();}}
}
加载成功
修改成功
修改成功
删除、查询操作 SearchTest.java
package test;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;/*** 删除、查询数据库操作* @author ruochen* @version 1.0*/
public class SearchTest {public static void main(String[] args) {Connection conn = DBConfig.getConnection();try {Statement st = conn.createStatement(); PreparedStatement ps = conn.prepareStatement("delete from student where id=?");ps.setString(1, "0002");ps.executeUpdate();System.out.println("删除成功");ResultSet rs = st.executeQuery("select * from student");while (rs.next()) {System.out.println(rs.getString("id") + "\t"+ rs.getString("name") + "\t" + rs.getShort("score"));}st.close();DBConfig.closeConnection(rs, ps, conn);} catch (Exception e) {e.printStackTrace();}}}
加载成功
删除成功
0001 小王 80
0003 小张 60
在Java与MySQL数据库的交响乐中，我们已经编织了一幅连接与交互的复杂图景。想象一下，Java应用程序如同一位指挥家，挥舞着JDBC的指挥棒，精准地引导着数据流在应用程序与数据库之间穿梭。每一个Connection对象都是一根弦，每一个Statement或PreparedStatement都是一段旋律，而ResultSet则是那令人心醉的乐章。
然而，这段旅程并非总是风平浪静。偶尔，数据库连接可能会因为网络波动或服务器负载而断开。这时，try-catch块就像一位经验丰富的调音师，迅速捕捉到异常并优雅地处理它们，确保应用程序的流畅运行。连接池技术则如同一位精明的经理，优化资源分配，减少延迟，提升性能。
在编写Java代码以连接MySQL时，我们不仅需要关注功能的实现，更要注重代码的可维护性和可扩展性。通过使用配置文件来管理数据库连接参数，我们使得应用程序更加灵活，能够轻松适应不同的环境。通过采用面向接口的编程，我们使得代码更加模块化，易于测试和重用。
随着技术的不断进步，Java与MySQL的连接方式也在不断演进。从传统的JDBC到现代的ORM框架，如Hibernate和MyBatis，我们有了更多的工具和选择来简化数据库操作，提高开发效率。这些框架如同一位位技艺高超的工匠，将繁琐的数据库操作转化为简洁而强大的API。
在结束这段关于Java连接MySQL的讨论时，让我们铭记，技术的世界没有终点，只有不断前进的旅程。每一次代码的编写和调试，都是我们与数据库世界对话的一部分。通过不断学习和实践，我们不仅能够解决当前面临的技术挑战，还能够预见并应对未来可能出现的问题，为组织的数字化转型和业务增长提供坚实的支持。
所以，让我们继续在Java与MySQL的广阔天地中探索，用我们的智慧和热情，书写连接与交互的辉煌篇章。记住，技术的世界永远欢迎那些勇于探索、不断创新的灵魂。
