如何在C# OdbcCommand中执行带变量的多语句？执行失败求助

我帮你排查下这个问题，主要有几个关键点导致执行失败，咱们一步步解决：

1. ODBC连接未启用多语句与用户变量支持 #

你的SQL是由多个语句组成的（设置隔离级别、变量赋值、分页查询、恢复隔离级别），但MySQL ODBC驱动默认不允许执行多语句，同时对用户变量（比如@row）的支持也默认关闭，这是导致执行失败的核心原因。

解决方法：修改连接字符串 #

在你的ODBC连接字符串中添加两个关键参数：

• AllowMultiQueries=True：允许执行多个SQL语句
• Allow User Variables=True：启用用户变量支持

示例连接字符串：

Driver={MySQL ODBC 8.0 Unicode Driver};Server=你的服务器地址;Database=你的数据库名;User=用户名;Password=密码;AllowMultiQueries=True;Allow User Variables=True;

2. 代码资源管理不够严谨 #

你手动处理连接的Close和Dispose容易出现异常泄漏（比如Con.Open()失败后，Close操作可能不会执行），建议用using语句自动管理资源，它会在代码块结束时自动释放连接、命令等资源，避免潜在错误。

优化后的代码： #

DataTable ExecuteCommand(string sql)
{
    DataTable dt = new DataTable();
    
    // 使用using自动管理连接和命令的生命周期，无需手动Close/Dispose
    using (OdbcConnection con = new OdbcConnection(ConnectionString))
    using (OdbcCommand sqlCommand = new OdbcCommand(sql, con))
    {
        try
        {
            con.Open();
            using (OdbcDataAdapter da = new OdbcDataAdapter(sqlCommand))
            {
                da.Fill(dt);
            }
        }
        catch (Exception ex)
        {
            // 这里可以添加日志记录等操作，方便排查具体错误
            throw; // 重新抛出异常，让上层逻辑处理
        }
    }
    
    return dt;
}

3. 可选优化：用.NET API替代SQL设置隔离级别 #

你可以通过OdbcConnection的IsolationLevel属性直接设置事务隔离级别，比执行SQL语句更简洁可靠，还能减少多语句的依赖：

DataTable ExecuteCommand(string sql)
{
    DataTable dt = new DataTable();
    
    using (OdbcConnection con = new OdbcConnection(ConnectionString))
    {
        try
        {
            con.Open();
            // 设置隔离级别为READ UNCOMMITTED
            con.IsolationLevel = System.Data.IsolationLevel.ReadUncommitted;
            
            // 只保留变量赋值和查询语句，去掉前后的SET语句
            string simplifiedSql = @"set @row=0; 
select * from ( 
    select @row:=@row+1 as my____row_num, cities.`cityid`, cities.`cityname`, cities.`countryid`, cities.`countryname` , '1' as my____data_row_created , '1' as my____data_row_updated 
    from `cities` 
) p where my____row_num>=101 and my____row_num<=200;";
            
            using (OdbcCommand sqlCommand = new OdbcCommand(simplifiedSql, con))
            using (OdbcDataAdapter da = new OdbcDataAdapter(sqlCommand))
            {
                da.Fill(dt);
            }
            
            // 恢复隔离级别为REPEATABLE READ
            con.IsolationLevel = System.Data.IsolationLevel.RepeatableRead;
        }
        catch (Exception ex)
        {
            throw;
        }
    }
    
    return dt;
}

这样修改后，你的查询应该就能正常执行了。

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