Springboot触发器实现mysql数据表的创建及增删改查

Spring Boot并不提供触发器的实现，这是MySQL数据库的功能。但是，你可以在Spring Boot应用程序中使用JdbcTemplate或Spring Data JPA来执行MySQL触发器。

以下是一个例子，展示如何使用JdbcTemplate和MySQL触发器：

1. 创建MySQL数据表

CREATE TABLE user (
  id INT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(50) NOT NULL,
  email VARCHAR(50) NOT NULL
);

2. 创建MySQL触发器

CREATE TRIGGER user_insert
AFTER INSERT ON user
FOR EACH ROW
BEGIN
  INSERT INTO user_audit (user_id, action) VALUES (NEW.id, 'insert');
END;

3. 在Spring Boot应用程序中使用JdbcTemplate执行MySQL触发器

首先，需要在pom.xml文件中添加JdbcTemplate依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

然后，创建一个JdbcTemplate实例并使用它来执行SQL语句：

@Autowired
private JdbcTemplate jdbcTemplate;

public void createUser(String name, String email) {
    String sql = "INSERT INTO user (name, email) VALUES (?, ?)";
    jdbcTemplate.update(sql, name, email);
}

当调用createUser方法时，将会触发MySQL触发器，该触发器将在user_audit表中插入一条新记录。

4. 在Spring Boot应用程序中使用Spring Data JPA执行MySQL触发器

首先，需要在pom.xml文件中添加Spring Data JPA依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

然后，创建一个JpaRepository接口并使用它来执行SQL语句：

public interface UserRepository extends JpaRepository<User, Long> {
    @Modifying
    @Query(value = "INSERT INTO user (name, email) VALUES (:name, :email)", nativeQuery = true)
    void createUser(@Param("name") String name, @Param("email") String email);
}

当调用createUser方法时，将会触发MySQL触发器，该触发器将在user_audit表中插入一条新记录。

5. 实现增删改查方法

在Spring Boot应用程序中，你可以使用JdbcTemplate或Spring Data JPA来实现增删改查方法，例如：

// 使用JdbcTemplate
public List<User> getAllUsers() {
    String sql = "SELECT * FROM user";
    return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(User.class));
}

// 使用Spring Data JPA
public List<User> getAllUsers() {
    return userRepository.findAll();
}

// 使用JdbcTemplate
public void updateUser(Long id, String name, String email) {
    String sql = "UPDATE user SET name = ?, email = ? WHERE id = ?";
    jdbcTemplate.update(sql, name, email, id);
}

// 使用Spring Data JPA
public void updateUser(Long id, String name, String email) {
    Optional<User> optionalUser = userRepository.findById(id);
    if (optionalUser.isPresent()) {
        User user = optionalUser.get();
        user.setName(name);
        user.setEmail(email);
        userRepository.save(user);
    }
}

// 使用JdbcTemplate
public void deleteUser(Long id) {
    String sql = "DELETE FROM user WHERE id = ?";
    jdbcTemplate.update(sql, id);
}

// 使用Spring Data JPA
public void deleteUser(Long id) {
    userRepository.deleteById(id);
}