java连接sqlserver数据库实现增删改查（java连接mysql进行增删改查）

环境MySQL 5.5 版本eclipseMySQL 连接驱动 mysql-connector-java-5.1.18-bin.jarmysql8.0之前的版本与之后的版本使用的jar包是不同的，在使用时也有一定的区别。这里，我的 MySQL 版本为 5.5。

java连接mysql进行增删改查

环境

准备工作

增删查改操作

注意：要提前建立一个数据库，然后在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();}}}

/* * 若尘 */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());}}}

加载成功创建成功

/* * 若尘 */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();}}}

加载成功插入成功

/* * 若尘 */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();}}}

加载成功修改成功修改成功

/* * 若尘 */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

上面就是小居数码小编今天给大家介绍的关于（java连接mysql进行增删改查）的全部内容，希望可以帮助到你，想了解更多关于数码知识的问题，欢迎关注我们，并收藏，转发，分享。

94%的朋友还想知道的：

• 10款最出色的免费数据库管理工具推荐（免费数据库管理工具）
• java程序员必备软件和工具（最常用的java开发工具）
• 数据库索引调优（数据库索引和优化）
• 数据库索引是干什么用的（数据库索引是干啥的）

（425）个朋友认为回复得到帮助。