|
@@ -0,0 +1,34 @@
|
|
|
+package com.xy.config;
|
|
|
+
|
|
|
+import com.xy.utils.DataTime;
|
|
|
+import lombok.AllArgsConstructor;
|
|
|
+import lombok.SneakyThrows;
|
|
|
+import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.core.io.ClassPathResource;
|
|
|
+import org.springframework.core.io.Resource;
|
|
|
+import org.springframework.core.io.support.EncodedResource;
|
|
|
+import org.springframework.jdbc.datasource.init.ScriptUtils;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import javax.sql.DataSource;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 执行sql脚本
|
|
|
+ */
|
|
|
+@Service
|
|
|
+@AllArgsConstructor
|
|
|
+public class MysqlSyncConfig {
|
|
|
+
|
|
|
+ private DataSource dataSource;
|
|
|
+
|
|
|
+ @Bean
|
|
|
+ @SneakyThrows
|
|
|
+ public Boolean syncSql() {
|
|
|
+ String time = DataTime.getSring("yyyyMMdd");
|
|
|
+ Resource classPathResource = new ClassPathResource(String.format("prod/%s/%s.sql", time, time));
|
|
|
+ EncodedResource encodedResource = new EncodedResource(classPathResource, "utf-8");
|
|
|
+ ScriptUtils.executeSqlScript(dataSource.getConnection(), encodedResource);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+}
|