连接数据库代码的步骤(java连接mysql数据库的代码)-众学网

环境

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中填写你自己的数据库名称

建表操作 CreateTest.java

/* * 若尘 */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 小王 800003 小张 60