DNchngguo/sql/ExecuteSQLScript.java

import java.sql.*;
import java.io.*;
import java.nio.file.*;
import java.util.Scanner;

public class ExecuteSQLScript {
    public static void main(String[] args) {
        String url = "jdbc:dm://192.168.0.145:30236";
        String username = "WATERSHED";
        String password = "WaterShed./1224";
        
        try {
            // 加载DM JDBC驱动
            Class.forName("dm.jdbc.driver.DmDriver");
            
            // 建立数据库连接
            Connection conn = DriverManager.getConnection(url, username, password);
            System.out.println("数据库连接成功！");
            
            // 执行SQL脚本文件
            executeScript(conn, "watershed_model.sql");
            executeScript(conn, "watershed_facility.sql");
            executeScript(conn, "watershed_equipment.sql");
            
            // 关闭连接
            conn.close();
            System.out.println("所有SQL脚本执行完成！");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    
    private static void executeScript(Connection conn, String scriptFile) {
        try {
            System.out.println("正在执行脚本: " + scriptFile);
            
            // 读取SQL脚本文件
            String content = new String(Files.readAllBytes(Paths.get(scriptFile)));
            
            // 使用分号分割SQL语句
            Scanner scanner = new Scanner(content);
            scanner.useDelimiter(";");
            
            Statement stmt = conn.createStatement();
            
            while (scanner.hasNext()) {
                String sql = scanner.next().trim();
                if (!sql.isEmpty() && !sql.startsWith("--")) {
                    try {
                        stmt.execute(sql);
                    } catch (SQLException e) {
                        System.err.println("执行SQL失败: " + sql);
                        System.err.println("错误信息: " + e.getMessage());
                    }
                }
            }
            
            stmt.close();
            scanner.close();
            
            System.out.println("脚本 " + scriptFile + " 执行完成！");
        } catch (Exception e) {
            System.err.println("执行脚本 " + scriptFile + " 时出错:");
            e.printStackTrace();
        }
    }
}