Java连接MySQL数据库实现单条插入和批量插入的攻略如下:
步骤1:下载MySQL Connector/J驱动
在Java中连接MySQL数据库需要用到MySQL Connector/J驱动,我们可以从MySQL官网(https://dev.mysql.com/downloads/connector/j/)上下载最新版本的Connector/J驱动,根据操作系统和对应的JDK版本选择合适的安装包进行下载。
步骤2:导入驱动到项目中
将下载好的MySQL Connector/J驱动解压,然后将其中的jar包添加到Java项目中。如使用Maven管理项目,则在pom.xml文件中添加以下依赖项:
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.23</version>
</dependency>
步骤3:创建数据库和数据表
使用MySQL Workbench或其他MySQL客户端创建一个数据库,然后在该数据库中创建数据表,例如:
CREATE TABLE `user` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`name` varchar(50) NOT NULL,
`age` int(11) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
步骤4:编写Java代码进行数据库操作
单条插入示例:
import java.sql.*;
public class InsertDemo {
// JDBC连接信息
static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC";
// 数据库用户和密码
static final String USER = "root";
static final String PASS = "123456";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 打开连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// 执行插入操作
System.out.println("插入数据...");
stmt = conn.createStatement();
String sql = "INSERT INTO user (name, age) VALUES ('Tom', 18)";
stmt.executeUpdate(sql);
// 输出插入结果
System.out.println("插入成功!");
} catch (SQLException se) {
// 处理JDBC异常
se.printStackTrace();
} catch (Exception e) {
// 处理Class.forName异常
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) {
stmt.close();
}
} catch (SQLException se2) {
}
try {
if (conn != null) {
conn.close();
}
} catch (SQLException se) {
se.printStackTrace();
}
}
System.out.println("Goodbye!");
}
}
批量插入示例:
import java.sql.*;
public class BatchInsertDemo {
// JDBC连接信息
static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost:3306/test?serverTimezone=UTC";
// 数据库用户和密码
static final String USER = "root";
static final String PASS = "123456";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动
Class.forName("com.mysql.cj.jdbc.Driver");
// 打开连接
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// 执行插入操作
System.out.println("批量插入数据...");
stmt = conn.createStatement();
conn.setAutoCommit(false); // 设置手动提交事务
for (int i = 1; i <= 100000; i++) {
String sql = "INSERT INTO user (name, age) VALUES ('Tom" + i + "', " + i + ")";
stmt.addBatch(sql);
}
stmt.executeBatch();
conn.commit(); // 提交事务
// 输出插入结果
System.out.println("插入成功!");
} catch (SQLException se) {
// 处理JDBC异常
se.printStackTrace();
} catch (Exception e) {
// 处理Class.forName异常
e.printStackTrace();
} finally {
// 关闭资源
try {
if (stmt != null) {
stmt.close();
}
} catch (SQLException se2) {
}
try {
if (conn != null) {
conn.close();
}
} catch (SQLException se) {
se.printStackTrace();
}
}
System.out.println("Goodbye!");
}
}
以上就是Java连接MySQL数据库实现单条插入和批量插入的完整攻略,希望对你有所帮助!
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:java连接mysql数据库实现单条插入和批量插入 - Python技术站