使用 spring 数据 jpa 在启动时将数据保存到数据库
Saving data to db on startup using spring data jpa
我想在 spring 启动应用程序启动时将一些实体数据添加到数据库中。我正在使用 spring 数据 jpa 存储库将数据保存到数据库。我试过对方法和 ApplicationListener
接口等使用 @PostConstruct
注释,但完全没有成功。在这两种情况下都会执行代码,但不会将任何数据写入数据库。我怎样才能实现它?
代码:
@Component
public class DatabaseFillerOnStartup implements ApplicationListener {
@Autowired
private UserRepository userRepository;
private static Logger logger = LoggerFactory.getLogger(DatabaseFillerOnStartup.class);
@Override
public void onApplicationEvent(ApplicationEvent event) {
logger.info("===================================" +event.toString());
User user = new User("test");
user.setFirstName("test");
user.setLastName("test");
user.setEmail("test@test.com");
user.setContactNumber("1234567890");
userRepository.save(user);
}
}
配置:
@Configuration
@EnableTransactionManagement
@ComponentScan("com.furniturepool.bll.config" )
@PropertySource(value = "classpath:application.properties" )
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan("domain.package" );
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("spring.datasource.driver-class-name"));
dataSource.setUrl(environment.getRequiredProperty("spring.datasource.url"));
dataSource.setUsername(environment.getRequiredProperty("spring.datasource.username"));
dataSource.setPassword(environment.getRequiredProperty("spring.datasource.password"));
return dataSource;
}
private Properties hibernateProperties() {
Properties properties = new Properties();
properties.put("hibernate.dialect", environment.getRequiredProperty("hibernate.dialect"));
properties.put("hibernate.show_sql", environment.getRequiredProperty("hibernate.show_sql"));
properties.put("hibernate.format_sql", environment.getRequiredProperty("hibernate.format_sql"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager(SessionFactory s) {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(s);
return txManager;
}
}
存储库:
interface UserRepository extends CrudRepository<User, Long> {
}
确定你已经提交交易了吗?
或将您的 'userrepository' 代码和 spring-data-jpa xml 配置放在这里。
在没有任何其他配置的情况下,我将一个示例应用程序放在一起,它使用 H2 数据库作为存储,并使用 JpaRepository 来存储和检索用户。
spring-data-jpa-repository-example
只是 运行 我添加的测试。
Mysql 数据库的示例配置:
spring:
jpa:
show-sql: true
hibernate:
naming-strategy: org.hibernate.cfg.ImprovedNamingStrategy
dialect: org.hibernate.dialect.MySQL5Dialect
ddl-auto: create-drop
datasource:
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/testdb?createDatabaseIfNotExist=true
test-on-borrow: true
validation-query: SELECT 1
username: xxx
password: xxx
记得将 MySQL 添加到您的类路径中。
希望对您有所帮助。
贾斯汀
我想在 spring 启动应用程序启动时将一些实体数据添加到数据库中。我正在使用 spring 数据 jpa 存储库将数据保存到数据库。我试过对方法和 ApplicationListener
接口等使用 @PostConstruct
注释,但完全没有成功。在这两种情况下都会执行代码,但不会将任何数据写入数据库。我怎样才能实现它?
代码:
@Component
public class DatabaseFillerOnStartup implements ApplicationListener {
@Autowired
private UserRepository userRepository;
private static Logger logger = LoggerFactory.getLogger(DatabaseFillerOnStartup.class);
@Override
public void onApplicationEvent(ApplicationEvent event) {
logger.info("===================================" +event.toString());
User user = new User("test");
user.setFirstName("test");
user.setLastName("test");
user.setEmail("test@test.com");
user.setContactNumber("1234567890");
userRepository.save(user);
}
}
配置:
@Configuration
@EnableTransactionManagement
@ComponentScan("com.furniturepool.bll.config" )
@PropertySource(value = "classpath:application.properties" )
public class HibernateConfiguration {
@Autowired
private Environment environment;
@Bean
public LocalSessionFactoryBean sessionFactory() {
LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
sessionFactory.setDataSource(dataSource());
sessionFactory.setPackagesToScan("domain.package" );
sessionFactory.setHibernateProperties(hibernateProperties());
return sessionFactory;
}
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(environment.getRequiredProperty("spring.datasource.driver-class-name"));
dataSource.setUrl(environment.getRequiredProperty("spring.datasource.url"));
dataSource.setUsername(environment.getRequiredProperty("spring.datasource.username"));
dataSource.setPassword(environment.getRequiredProperty("spring.datasource.password"));
return dataSource;
}
private Properties hibernateProperties() {
Properties properties = new Properties();
properties.put("hibernate.dialect", environment.getRequiredProperty("hibernate.dialect"));
properties.put("hibernate.show_sql", environment.getRequiredProperty("hibernate.show_sql"));
properties.put("hibernate.format_sql", environment.getRequiredProperty("hibernate.format_sql"));
return properties;
}
@Bean
@Autowired
public HibernateTransactionManager transactionManager(SessionFactory s) {
HibernateTransactionManager txManager = new HibernateTransactionManager();
txManager.setSessionFactory(s);
return txManager;
}
}
存储库:
interface UserRepository extends CrudRepository<User, Long> {
}
确定你已经提交交易了吗? 或将您的 'userrepository' 代码和 spring-data-jpa xml 配置放在这里。
在没有任何其他配置的情况下,我将一个示例应用程序放在一起,它使用 H2 数据库作为存储,并使用 JpaRepository 来存储和检索用户。
spring-data-jpa-repository-example
只是 运行 我添加的测试。
Mysql 数据库的示例配置:
spring:
jpa:
show-sql: true
hibernate:
naming-strategy: org.hibernate.cfg.ImprovedNamingStrategy
dialect: org.hibernate.dialect.MySQL5Dialect
ddl-auto: create-drop
datasource:
driver-class-name: com.mysql.jdbc.Driver
url: jdbc:mysql://localhost:3306/testdb?createDatabaseIfNotExist=true
test-on-borrow: true
validation-query: SELECT 1
username: xxx
password: xxx
记得将 MySQL 添加到您的类路径中。
希望对您有所帮助。
贾斯汀