项目启动 sql 执行

pom.xml

@@ -18,7 +18,10 @@
         <java.version>1.8</java.version>
     </properties>
 
+
+
     <dependencies>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter</artifactId>
@@ -145,6 +148,12 @@
             <groupId>org.springframework.retry</groupId>
             <artifactId>spring-retry</artifactId>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/ant/ant -->
+        <dependency>
+            <groupId>ant</groupId>
+            <artifactId>ant</artifactId>
+            <version>1.7.0</version>
+        </dependency>
 
 
     </dependencies>

src/main/java/cn/quantgroup/cashloanflowboss/core/init/BossInit.java

+package cn.quantgroup.cashloanflowboss.core.init;
+
+
+import org.apache.tools.ant.Project;
+import org.apache.tools.ant.taskdefs.SQLExec;
+import org.apache.tools.ant.types.EnumeratedAttribute;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ResourceUtils;
+
+import java.io.File;
+
+/**
+ * function:
+ * date: 2019/10/25
+ *
+ * @author: suntao
+ */
+@Component
+public class BossInit implements CommandLineRunner {
+
+    @Value("${data.boss.url}")
+    private String url;
+    @Value("${data.boss.username}")
+    private String username;
+    @Value("${data.boss.password}")
+    private String password;
+    @Value("${spring.datasource.driverClassName}")
+    private String driverClassName;
+
+
+    @Override
+    public void run(String... strings) {
+        SQLExec sqlExec;
+        try {
+            String[] sql = {"/sql/base_data.sql"};
+            System.out.println("size: " + sql.length);
+            String path = ResourceUtils.getURL("classpath:").getPath();
+            System.out.println(path);
+
+            for(int i=0;i<sql.length;i++){
+                String a = sql[i];
+                System.out.println(a);
+                sqlExec = new SQLExec();
+
+                //设置数据库参数
+                sqlExec.setDriver(driverClassName);
+                sqlExec.setUrl(url);
+                sqlExec.setUserid(username);
+                sqlExec.setPassword(password);
+
+                sqlExec.setEncoding("UTF8");
+                //要执行的脚本
+                sqlExec.setSrc(new File(path + sql[i]));
+
+                //有出错的语句该如何处理
+                sqlExec.setOnerror((SQLExec.OnError)(EnumeratedAttribute.getInstance(
+                        SQLExec.OnError.class, "abort")));
+
+                sqlExec.setPrint(true); //设置是否输出
+
+                sqlExec.setProject(new Project()); // 要指定这个属性，不然会出错
+                sqlExec.execute();
+            }
+            return ;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ;
+        }
+    }
+}