要在 IntelliJ IDEA 中创建一个 Spring Boot 项目并实现基于 JdbcTemplate 的增删改查功能，以下是一个详细的步骤和代码示例。这个例子使用一个简单的用户信息表（users），并展示如何使用 JdbcTemplate` 的各种方法进行操作。
前文有介绍简单的jdbc操作，手写SQL。这次我们介绍下进阶级别的数据库操作方式。
springboot依赖之JDBC API手写sql 管理数据库
1. 创建 Spring Boot 项目
-
创建一个新的 Spring Boot 项目：
- 打开 IntelliJ IDEA。
- 选择
New Project>Spring Initializr。 - 输入项目名称，例如
springjdbc2。 - 添加依赖项：
Spring Web,Spring Data JPA,MySQL Driver和Spring JDBClombok。
-
配置数据库连接：
在src/main/resources/application.properties中配置数据库连接信息，例如：spring.application.name=spring-jdbc2 spring.datasource.url=jdbc:mysql://localhost:3306/spring-dependencies?useSSL=false&serverTimezone=UTC spring.datasource.username=root spring.datasource.password=root spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
2. 创建用户信息表users
CREATE TABLE users (
id INT AUTO_INCREMENT PRIMARY KEY,
name VARCHAR(255) NOT NULL,
email VARCHAR(255) NOT NULL,
age INT NOT NULL
);
3. 创建用户实体类User
在 src/main/java/com/example/jdbc_example/model/User.java 中创建一个简单的用户实体类：
package com.spedencencies.springjdbc2.model;
import lombok.Data;
/**
* @author zhizhou 2024/8/26 23:30
*/
@Data
public class User {
private int id;
private String name;
private String email;
private int age;
}
4. 创建 JdbcTemplate 实现类
在 repository/UserRepository.java 中创建一个 UserRepository 类，用于处理数据库操作：
package com.spedencencies.springjdbc2.rrepository;
import com.spedencencies.springjdbc2.model.User;
import org.springframework.stereotype.Repository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
/**
* @author zhizhou 2024/8/26 23:31
*/
@Repository
public class UserRepository {
@Autowired
private JdbcTemplate jdbcTemplate;
// 添加用户
public int addUser(User user) {
String sql = "INSERT INTO users (name, email, age) VALUES (?, ?, ?)";
return jdbcTemplate.update(sql, user.getName(), user.getEmail(), user.getAge());
}
// 删除用户
public int deleteUser(int id) {
String sql = "DELETE FROM users WHERE id = ?";
return jdbcTemplate.update(sql, id);
}
// 更新用户
public int updateUser(User user) {
String sql = "UPDATE users SET name = ?, email = ?, age = ? WHERE id = ?";
return jdbcTemplate.update(sql, user.getName(), user.getEmail(), user.getAge(), user.getId());
}
// 查询用户列表
public List<User> getAllUsers() {
String sql = "SELECT * FROM users";
return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
}
// 使用 queryForObject 查询单个用户
public User getUserById(int id) {
String sql = "SELECT * FROM users WHERE id = ?";
return jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(User.class), id);
}
// 使用 queryForMap 查询用户
public Map<String, Object> getUserAsMap(int id) {
String sql = "SELECT * FROM users WHERE id = ?";
return jdbcTemplate.queryForMap(sql, id);
}
// 使用 queryForList 查询多条记录
public List<Map<String, Object>> getAllUsersAsMap() {
String sql = "SELECT * FROM users";
return jdbcTemplate.queryForList(sql);
}
// 使用 queryForRowSet 查询
public void queryForRowSetExample() {
String sql = "SELECT * FROM users";
var rowSet = jdbcTemplate.queryForRowSet(sql);
while (rowSet.next()) {
int id = rowSet.getInt("id");
String name = rowSet.getString("name");
System.out.println("ID: " + id + ", Name: " + name);
}
}
// 使用 batchUpdate 批量插入
public int[][] batchInsertUsers(List<User> users) {
String sql = "INSERT INTO users (name, email, age) VALUES (?, ?, ?)";
return jdbcTemplate.batchUpdate(sql, users, users.size(), (ps, user) -> {
ps.setString(1, user.getName());
ps.setString(2, user.getEmail());
ps.setInt(3, user.getAge());
});
}
}
5. 测试 JdbcTemplate 功能
在 SpringJdbc2Application 中，可以编写简单的测试代码来验证上述功能：
package com.spedencencies.springjdbc2;
import com.spedencencies.springjdbc2.model.User;
import com.spedencencies.springjdbc2.rrepository.UserRepository;
import org.apache.tomcat.util.json.JSONParser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.util.ArrayList;
import java.util.List;
@SpringBootApplication
public class SpringJdbc2Application implements CommandLineRunner{
@Autowired
private UserRepository userRepository;
public static void main(String[] args) {
SpringApplication.run(SpringJdbc2Application.class, args);
}
@Override
public void run(String... args) {
// 添加用户
User user = new User();
user.setName("一周一志");
user.setEmail("zhizhou@example.com");
user.setAge(18);
userRepository.addUser(user);
// 查询用户
User queriedUser = userRepository.getUserById(3);
System.out.println("Queried User: " + queriedUser.getName());
// 更新用户
queriedUser.setName("一周一志程序员 Updated");
userRepository.updateUser(queriedUser);
// 查询所有用户
List<User> allUsers = userRepository.getAllUsers();
allUsers.forEach(u -> System.out.println("User: " + u.getName()));
// 删除用户
//userRepository.deleteUser(2);
// 测试其他查询方法
userRepository.queryForRowSetExample();
// 批量插入用户
List<User> users = new ArrayList<>();
User user1 = new User();
user1.setName("一周一志");
user1.setEmail("zhizhou@example.com");
user1.setAge(18);
users.add(user1);
User user2 = new User();
user2.setName("一周一志");
user2.setEmail("1184795629@qq.com");
user2.setAge(18);
users.add(user2);
int[][] res = userRepository.batchInsertUsers(users);
//打印成json字符串
for (int i = 0; i < res.length; i++) {
for (int j = 0; j < res[i].length; j++)
System.out.println("res[" + i + "][" + j + "] = " + res[i][j]);
}
}
}
6. 运行项目
启动 Spring Boot 项目，控制台输出你在测试代码中执行的各种数据库操作。
结论
通过上述步骤，在 Spring Boot 项目使用 JdbcTemplate 实现了一个用户信息表的增删改查功能。这个例子展示了 JdbcTemplate 的多个高级操作方法，包括 query、queryForObject、queryForMap、queryForList、queryForRowSet 和 batchUpdate，这些方法可以帮助你更灵活地操作数据库。
