java连接数据库增删改查
时间: 2023-11-09 09:51:49 浏览: 106
Java连接数据库的增删改查可以通过使用JdbcTemplate来实现。首先,你需要配置数据源,确保能够连接到数据库。在配置文件中设置数据库的驱动类、URL、用户名和密码。
接下来,你需要创建数据库和表。可以通过运行SQL语句来创建数据库和表,例如创建一个名为testdb的数据库并在其中创建一个名为user的表。
然后,你可以在数据访问层(DAO)进行增删改查的操作。可以先创建一个接口,定义对数据库的基本增删改查操作,然后创建一个实现类,使用JdbcTemplate来实现这些操作。
如下是一个简单的示例:
```java
// 配置数据源
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/testdb?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false&allowPublicKeyRetrieval=true
spring.datasource.username=root
spring.datasource.password=123456
// 创建数据库和表
DROP DATABASE IF EXISTS `testdb`;
create database testdb;
Use testdb;
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`user_id` int NOT NULL AUTO_INCREMENT COMMENT '用户 ID',
`user_name` varchar(255) DEFAULT NULL COMMENT '用户名',
`status` varchar(255) DEFAULT NULL COMMENT '用户状态',
PRIMARY KEY (`user_id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;
// 数据访问层DAO
// 接口CRUD
public interface UserDao {
User getById(int id);
List<User> getAll();
void insert(User user);
void update(User user);
void delete(int id);
}
// DAO层实现类--JdbcTemplate
@Repository
public class UserDaoImpl implements UserDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Override
public User getById(int id) {
String sql = "SELECT * FROM user WHERE user_id = ?";
return jdbcTemplate.queryForObject(sql, new Object[]{id}, new BeanPropertyRowMapper<>(User.class));
}
@Override
public List<User> getAll() {
String sql = "SELECT * FROM user"; return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
}
@Override
public void insert(User user) {
String sql = "INSERT INTO user (user_name, status) VALUES (?, ?)";
jdbcTemplate.update(sql, user.getUserName(), user.getStatus());
}
@Override
public void update(User user) {
String sql = "UPDATE user SET user_name = ?, status = ? WHERE user_id = ?";
jdbcTemplate.update(sql, user.getUserName(), user.getStatus(), user.getUserId());
}
@Override
public void delete(int id) {
String sql = "DELETE FROM user WHERE user_id = ?";
jdbcTemplate.update(sql, id);
}
}
```
阅读全文