如何实现SQL Server与Oracle脚本的无人值守连续执行？

当然可以实现！你完全不用手动来回切换服务器，下面给你几个实用的方案，都是我实际用过或者见过同行常用的：

方案1：用批处理（Windows）/Shell脚本（Linux）串联执行 #

这个方案最直接，利用SQL Server的sqlcmd和Oracle的sqlplus命令行工具，写一个脚本依次调用它们执行对应的查询。

Windows批处理示例 #

@echo off
:: 执行SQL Server（Server1）的查询脚本
sqlcmd -S Server1 -U your_sql_username -P your_sql_password -i "C:\scripts\sqlserver_queries.sql"

:: 检查SQL Server脚本是否执行成功（可选，增加容错）
if %errorlevel% equ 0 (
    echo ✅ SQL Server脚本执行完成，开始执行Oracle脚本...
    :: 执行Oracle（Server2）的查询脚本
    sqlplus your_oracle_username/your_oracle_password@Server2:1521/ORCL @C:\scripts\oracle_queries.sql
) else (
    echo ❌ SQL Server脚本执行失败，终止流程
    exit /b 1
)

Linux Shell脚本示例 #

#!/bin/bash
# 执行SQL Server查询
/opt/mssql-tools/bin/sqlcmd -S Server1 -U your_sql_username -P your_sql_password -i "/scripts/sqlserver_queries.sql"

# 检查执行状态
if [ $? -eq 0 ]; then
    echo "✅ SQL Server脚本执行完成，开始执行Oracle脚本..."
    # 执行Oracle查询
    sqlplus your_oracle_username/your_oracle_password@//Server2:1521/ORCL @/scripts/oracle_queries.sql
else
    echo "❌ SQL Server脚本执行失败，终止流程"
    exit 1
fi

注意： 不要硬编码密码，可以用环境变量（比如%SQL_PWD%/$SQL_PWD）或者加密文件来存储，避免安全风险；另外要确保sqlcmd和sqlplus在系统PATH中，或者使用完整路径调用。

方案2：用Python脚本（跨平台，灵活可控） #

如果需要更复杂的逻辑（比如判断查询结果、记录详细日志、处理异常），Python是个不错的选择，通过数据库驱动直接连接两个数据库并顺序执行查询。

首先需要安装依赖库：

pip install pyodbc cx-Oracle

然后编写脚本：

import pyodbc
import cx_Oracle

# --------------------------
# 执行SQL Server（Server1）的查询
# --------------------------
sql_server_conn_str = (
    "DRIVER={ODBC Driver 17 for SQL Server};"
    "SERVER=Server1;"
    "DATABASE=YourTargetDB;"
    "UID=your_sql_username;"
    "PWD=your_sql_password;"
)

try:
    with pyodbc.connect(sql_server_conn_str) as sql_conn:
        cursor = sql_conn.cursor()
        # 可以直接写查询，或者读取SQL文件内容
        with open("sqlserver_queries.sql", "r", encoding="utf-8") as f:
            sql_queries = f.read().split(";")
        
        for idx, query in enumerate(sql_queries, 1):
            query = query.strip()
            if not query:
                continue
            print(f"🔍 执行SQL Server第{idx}个查询: {query[:50]}...")
            cursor.execute(query)
            # 如果是写操作（INSERT/UPDATE/DELETE），需要提交事务
            if query.strip().upper().startswith(("INSERT", "UPDATE", "DELETE")):
                sql_conn.commit()
    print("✅ SQL Server所有查询执行完成")
except Exception as e:
    print(f"❌ SQL Server执行出错: {str(e)}")
    exit(1)

# --------------------------
# 执行Oracle（Server2）的查询
# --------------------------
try:
    # 配置Oracle连接
    oracle_dsn = cx_Oracle.makedsn("Server2", 1521, service_name="ORCL")
    with cx_Oracle.connect(
        user="your_oracle_username",
        password="your_oracle_password",
        dsn=oracle_dsn
    ) as oracle_conn:
        cursor = oracle_conn.cursor()
        with open("oracle_queries.sql", "r", encoding="utf-8") as f:
            oracle_queries = f.read().split(";")
        
        for idx, query in enumerate(oracle_queries, 1):
            query = query.strip()
            if not query:
                continue
            print(f"🔍 执行Oracle第{idx}个查询: {query[:50]}...")
            cursor.execute(query)
            # Oracle写操作同样需要提交
            if query.strip().upper().startswith(("INSERT", "UPDATE", "DELETE")):
                oracle_conn.commit()
    print("✅ Oracle所有查询执行完成")
except Exception as e:
    print(f"❌ Oracle执行出错: {str(e)}")
    exit(1)

注意： Windows环境需要安装SQL Server ODBC驱动，Linux/macOS需要配置Oracle Instant Client才能正常连接。

方案3：用ETL工具（企业级场景首选） #

如果是企业环境，推荐用SQL Server Integration Services（SSIS）或者Oracle Data Integrator（ODI）这类ETL工具：

• 在SSIS中创建一个包，添加两个Execute SQL Task任务，第一个连接SQL Server执行查询，第二个连接Oracle执行查询，把它们按顺序串联起来；
• 可以轻松添加错误处理、日志记录、调度执行（比如用SQL Server Agent定时跑），适合复杂的批量处理场景。

内容的提问来源于stack exchange，提问作者x1PatientZero1x