2

我有一个 CLR 触发器，它使用BeginInvoke. 在存储过程中，我尝试调用 SqlComman，但我得到：请求的操作需要 Sql Server 执行线程。当前线程是由用户代码或其他非 Sql Server 引擎代码启动的。

我必须在 SP 中做这些事情，并且BeginInvoke由于等待，我必须用 调用 SP。

编码：

[SqlProcedure()]
public static void MySendData( String crudType, String sourceTable, ... ) {
    SqlCommand sqlDeleteComm;

    String temp = String.Empty;

    using( SqlConnection conn = new SqlConnection( "context connection=true" ) ) {

        sqlDeleteComm = new SqlCommand( "DELETE FROM #TEMP_TABLE" );
        sqlDeleteComm.Connection = conn;

        try {
            conn.Open();
            sqlDeleteComm.ExecuteNonQuery();
            conn.Close();
        } catch( Exception ex ) {
            // --- here ---
            // The requested operation requires a Sql Server execution thread.  The current thread was started by user code or other non-Sql Server engine code.
        }
    }
    ...
}

[Microsoft.SqlServer.Server.SqlTrigger( Name = "MyTrigger", Target = "MyTable", Event = "FOR UPDATE, INSERT, DELETE" )]
public static void MyTrigger() {
    SqlTriggerContext myContext = SqlContext.TriggerContext;
    MyDelagate d;
    SqlCommand sqlComm;
    SqlDataReader reader;

    if( connection.State != ConnectionState.Open ) {
        connection.Open();
    }

    switch( myContext.TriggerAction ) {
        case TriggerAction.Update:
            sqlComm = new SqlCommand( "SELECT X, Y FROM Inserted" );
            sqlComm.Connection = connection;

            reader = sqlComm.ExecuteReader();
            try {
                reader.Read();
                d = new MyDelagate( MySendData );
                d.BeginInvoke( "Update", "MyTable", ( Int32 )reader[ 0 ], ( Int32 )reader[ 1 ], null, null );
            } catch( Exception ex ) {
            } finally {
                reader.Close();
            }
            break;
            ...
    }
}

对于 SP 中的所有调用 SQL 查询，我怎么能这样做？

4

2 回答 2

1

您不能在 SQL Server 运行 CLR 代码的线程之外使用上下文连接；这是为了确保服务器的可靠性 - SQL Server 使用自定义 CLR 托管，我很惊讶它允许您旋转自己的线程。您可以使用 T-SQL 调用MySendData，在 context 上MyTrigger使用标准 ADO.NET ，但它无法在单独的线程中运行。如果您真的想要数据库级别的异步/并行，请查看 SQL Server Broker。SqlCommandSqlConnection

于 2012-03-22T12:16:15.640 回答
0

如果您可以避免使用上下文连接，则可以规避此问题。使用常规连接字符串创建新的 SqlConnection（必要时将 Enlist 选项设置为 false 以防止使用相同的事务上下文）将允许您在 SQL CLR 上下文中使用多线程。

于 2019-08-04T14:08:21.133 回答