Java 连接操作 MySQL 数据库(增删查改操作)【奔跑吧!JAVA】
【摘要】 Java 连接操作 MySQL 数据库(增删查改操作)
MySQL 操作有不懂的,可查看我的 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
中填写你自己的数据库名称
/*
* 若尘
*/
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.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 小王 80
0003 小张 60
mysql-connector-java-5.1.18-bin.jar
链接:https://pan.baidu.com/s/1Ep7pKfFnHq_S8oN1Z4kaNg
提取码:tz8n
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱:
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论(0)