1 package com.jt.mongo.demo.modules.init; 2 3 import org.slf4j.Logger; 4 import org.slf4j.LoggerFactory; 5 import org.springframework.context.ApplicationListener; 6 import org.springframework.context.event.ContextRefreshedEvent; 7 import org.springframework.core.io.ClassPathResource; 8 import org.springframework.jdbc.datasource.init.ResourceDatabasePopulator; 9 import org.springframework.stereotype.Component;10 11 import javax.annotation.Resource;12 import javax.sql.DataSource;13 import java.sql.SQLException;14 15 @Component16 public class SqlScriptInitExecutor implements ApplicationListener{17 18 private static final Logger LOGGER = LoggerFactory.getLogger(SqlScriptInitExecutor.class);19 20 @Resource21 private DataSource mysqlDataSource;22 23 @Override24 public void onApplicationEvent(ContextRefreshedEvent event) {25 initMySqlTables();26 }27 28 private void initMySqlTables() {29 try {30 31 ResourceDatabasePopulator populator = new ResourceDatabasePopulator();32 populator.addScript(new ClassPathResource("sql/mysql_pdca_manager.sql"));33 populator.populate(mysqlDataSource.getConnection());34 35 LOGGER.info("init pdca manager tables success.");36 37 } catch (SQLException e) {38 LOGGER.error("init pdca manager tables error", e);39 }40 }41 }
ContextRefreshedEvent:
Event raised when an {@code ApplicationContext} gets initialized or refreshed. 当容器初始化或者重启之后实例化到容器中,然后监听他的listener就会执行