2012-07-08 55 views
1

我有一个应用程序可以添加新的登录到sql服务器,然后将其映射到所有的数据库,并使其'db_owner'(这些是要求...)。 当我构建应用程序时,我使用了SMO并且一切都很完美。 现在的需求已经改变,我不能再使用SMO:( 所以我需要从我的应用程序运行T-SQL命令而不是... 我的问题是当我运行应用程序什么都没有发生在SQL服务器 - 登录不会被添加,它不会被映射到所有数据库....但是当我在SQL服务器管理工​​作室中执行这些行时,它工作得很好...从.net运行T-SQL命令

这些是命令 -

create login dbUser WITH PASSWORD = 'passsword'; 

use DB_MyLog; 
create user dbUser for login dbUser; 
use DB_MyLog 
EXEC sp_addrolemember 'db_owner','dbUser' 

在我的应用程序运行它们这样的 -

string connString = "Data Source=" + ConfigurationManager.AppSettings.Get("localhost_SQLEXPRESS") 
            + ";Initial Catalog=" + "master" + ";User ID=" + ConfigurationManager.AppSettings.Get("user") 
            + ";Password=" + ConfigurationManager.AppSettings.Get("password"); 

     SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(connString); 

     builder.AsynchronousProcessing = true; 

     using (SqlConnection sqlConnection1 = new SqlConnection(builder.ConnectionString)) 
     { 

      using (SqlCommand cmd = new SqlCommand("CREATE LOGIN " + ConfigurationManager.AppSettings.Get("dbUser") + 
                " WITH PASSWORD=N'" + ConfigurationManager.AppSettings.Get("dbUserPass") + "' " 
                , sqlConnection1)) 
      { 

       sqlConnection1.Open(); 

       cmd.BeginExecuteNonQuery(); 

      } 
     } 

和在我运行的另一种方法 -

string connString = "Data Source=" + ConfigurationManager.AppSettings.Get("localhost_SQLEXPRESS") 
       + ";Initial Catalog=" + "master" + ";User ID=" + ConfigurationManager.AppSettings.Get("user") 
       + ";Password=" + ConfigurationManager.AppSettings.Get("password"); 

     SqlConnectionStringBuilder builder = new SqlConnectionStringBuilder(connString); 

     builder.AsynchronousProcessing = true; 

     using (SqlConnection sqlConnection1 = new SqlConnection(builder.ConnectionString)) 
     { 
      //get all databases 
      using (SqlCommand cmd = new SqlCommand("SELECT * FROM sys.sysdatabases", sqlConnection1)) 
      { 

       sqlConnection1.Open(); 
       SqlDataReader reader = cmd.ExecuteReader(); 

       // Call Read before accessing data. 
       while (reader.Read()) 
       { 
        using (SqlConnection sqlConnection2 = new SqlConnection(builder.ConnectionString)) 
        { 
         sqlConnection2.Open(); 
         using (SqlCommand cmd1 = new SqlCommand("use " + reader[0].ToString() + ";" + 
                   "create user " + ConfigurationManager.AppSettings.Get("dbUser") + " for login " + ConfigurationManager.AppSettings.Get("dbUser") + ";" + 
                   "use " + reader[0].ToString() + 
                   " EXEC sp_addrolemember 'db_owner','" + ConfigurationManager.AppSettings.Get("dbUSer") + "'" 
                   , sqlConnection2)) 
         { 
          cmd1.BeginExecuteNonQuery(); 

         } 

        } 
       } 

       // Call Close when done reading. 
       reader.Close(); 

      } 
     } 
+4

如果使用'BeginExecuteNonQuery'并发生错误,则它只会在回调处理程序中变为可见。也许调用'ExecuteNonQuery'而不是'BeginExecuteNonQuery'。 – Andomar 2012-07-08 08:34:38

+0

@Andomar当我将BeginExecuteNonQuery更改为ExecuteNonQuery时,我能够捕捉到我的异常并修复了我的错误....现在它可以正常工作,谢谢...如果将此建议添加到答案中,我会接受它... – 2012-07-08 09:17:18

回答

1

如果使用BeginExecuteNonQuery并且发生错误,它只会在回调处理程序中变为可见。也许请拨打ExecuteNonQuery而不是BeginExecuteNonQuery

1

而非SqlConnectionStringBuilder构建器,如果设置它的工作重新使用“;初始目录=”用于sqlConnection2 +读卡器[0]的ToString()?您可以省略USE语句,然后发出两个单独的SqlCommands(CREATE USER,EXEC)。

分离这些步骤可能会帮助您找出哪些语句失败,以及在while()循环内使用try/catch的数据库。