So führen Sie eine .SQL-Skriptdatei mit c # aus

Ich bin mir sicher, dass diese Frage bereits beantwortet wurde, konnte jedoch mit dem Suchwerkzeug keine Antwort finden.

Mit c # möchte ich eine .sql-Datei ausführen. Die SQL-Datei enthält mehrere SQL-Anweisungen, von denen einige über mehrere Zeilen verteilt sind. Ich habe versucht, die Datei einzulesen und die Datei mit ODP.NET auszuführen. Ich glaube jedoch nicht, dass ExecuteNonQuery wirklich dafür ausgelegt ist.

Also habe ich versucht, sqlplus über das Laichen eines Prozesses zu verwenden. Wenn ich den Prozess jedoch nicht mit UseShellExecute erzeugt habe, das auf true gesetzt ist, würde sqlplus hängen bleiben und niemals beendet werden. Hier ist der Code, der nicht funktioniert.

Process p = new Process();
p.StartInfo.UseShellExecute = false;
p.StartInfo.RedirectStandardOutput = true;
p.StartInfo.FileName = "sqlplus";
p.StartInfo.Arguments = string.Format("xx/xx@{0} @{1}", in_database, s);
p.StartInfo.CreateNoWindow = true;

bool started = p.Start();
p.WaitForExit();

WaitForExit kehrt nie zurück ... Es sei denn, ich setze UseShellExecute auf true. Ein Nebeneffekt von UseShellExecute ist, dass Sie die umgeleitete Ausgabe nicht erfassen können.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using Microsoft.SqlServer.Management.Smo;
using Microsoft.SqlServer.Management.Common;
using System.IO;
using System.Data.SqlClient;

public partial class ExcuteScript : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
    string sqlConnectionString = @"Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=ccwebgrity;Data Source=SURAJIT\SQLEXPRESS";

    string script = File.ReadAllText(@"E:\Project Docs\MX462-PD\MX756_ModMappings1.sql");

    SqlConnection conn = new SqlConnection(sqlConnectionString);

    Server server = new Server(new ServerConnection(conn));

    server.ConnectionContext.ExecuteNonQuery(script);
    }
}

Ich habe diese Lösung mit Microsoft.SqlServer.Management ausprobiert, aber mit .NET 4.0 hat sie nicht gut funktioniert. Daher habe ich eine andere Lösung nur mit dem .NET libs-Framework geschrieben.

string script = File.ReadAllText(@"E:\someSqlScript.sql");

// split script on GO command
IEnumerable<string> commandStrings = Regex.Split(script, @"^\s*GO\s*$", RegexOptions.Multiline | RegexOptions.IgnoreCase);

Connection.Open();
foreach (string commandString in commandStrings)
{
    if (!string.IsNullOrWhiteSpace(commandString.Trim()))
    {
        using(var command = new SqlCommand(commandString, Connection))
        {
            command.ExecuteNonQuery();
        }
    }
}     
Connection.Close();

Dies funktioniert unter Framework 4.0 oder höher. Unterstützt "GO". Zeigen Sie auch die Fehlermeldung, die Zeile und den SQL-Befehl an.

using System.Data.SqlClient;

        private bool runSqlScriptFile(string pathStoreProceduresFile, string connectionString)
    {
        try
        {
            string script = File.ReadAllText(pathStoreProceduresFile);

            // split script on GO command
            System.Collections.Generic.IEnumerable<string> commandStrings = Regex.Split(script, @"^\s*GO\s*$",
                                     RegexOptions.Multiline | RegexOptions.IgnoreCase);
            using (SqlConnection connection = new SqlConnection(connectionString))
            {
                connection.Open();
                foreach (string commandString in commandStrings)
                {
                    if (commandString.Trim() != "")
                    {
                        using (var command = new SqlCommand(commandString, connection))
                        {
                        try
                        {
                            command.ExecuteNonQuery();
                        }
                        catch (SqlException ex)
                        {
                            string spError = commandString.Length > 100 ? commandString.Substring(0, 100) + " ...\n..." : commandString;
                            MessageBox.Show(string.Format("Please check the SqlServer script.\nFile: {0} \nLine: {1} \nError: {2} \nSQL Command: \n{3}", pathStoreProceduresFile, ex.LineNumber, ex.Message, spError), "Warning", MessageBoxButtons.OK, MessageBoxIcon.Warning);
                            return false;
                        }
                    }
                    }
                }
                connection.Close();
            }
        return true;
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.Message, "Warning", MessageBoxButtons.OK, MessageBoxIcon.Warning);
            return false;
        }
    }

Fügen Sie den Befehl zum Ausführen des SQL-Skripts in eine Batchdatei ein und führen Sie den folgenden Code aus

string batchFileName = @"c:\batosql.bat";
string sqlFileName = @"c:\MySqlScripts.sql";
Process proc = new Process();
proc.StartInfo.FileName = batchFileName;
proc.StartInfo.Arguments = sqlFileName;
proc.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
proc.StartInfo.ErrorDialog = false;
proc.StartInfo.WorkingDirectory = Path.GetDirectoryName(batchFileName);
proc.Start();
proc.WaitForExit();
if ( proc.ExitCode!= 0 )

Schreiben Sie in die Batch-Datei so etwas (Beispiel für SQL Server)

osql -E -i %1

Das funktioniert bei mir:

public void updatedatabase()
{

    SqlConnection conn = new SqlConnection("Data Source=" + txtserver.Text.Trim() + ";Initial Catalog=" + txtdatabase.Text.Trim() + ";User ID=" + txtuserid.Text.Trim() + ";Password=" + txtpwd.Text.Trim() + "");
    try
    {

        conn.Open();

        string script = File.ReadAllText(Server.MapPath("~/Script/DatingDemo.sql"));

        // split script on GO command
        IEnumerable<string> commandStrings = Regex.Split(script, @"^\s*GO\s*$", RegexOptions.Multiline | RegexOptions.IgnoreCase);
        foreach (string commandString in commandStrings)
        {
            if (commandString.Trim() != "")
            {
                new SqlCommand(commandString, conn).ExecuteNonQuery();
            }
        }
        lblmsg.Text = "Database updated successfully.";

    }
    catch (SqlException er)
    {
        lblmsg.Text = er.Message;
        lblmsg.ForeColor = Color.Red;
    }
    finally
    {
        conn.Close();
    }
}

Zusätzliche Verbesserungen zu surajits hinzugefügt Antwort:

using System;
using Microsoft.SqlServer.Management.Smo;
using Microsoft.SqlServer.Management.Common;
using System.IO;
using System.Data.SqlClient;

namespace MyNamespace
{
    public partial class RunSqlScript : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {
            var connectionString = @"your-connection-string";
            var pathToScriptFile = Server.MapPath("~/sql-scripts/") + "sql-script.sql";
            var sqlScript = File.ReadAllText(pathToScriptFile);

            using (var connection = new SqlConnection(connectionString))
            {
                var server = new Server(new ServerConnection(connection));
                server.ConnectionContext.ExecuteNonQuery(sqlScript);
            }
        }
    }
}

Außerdem musste ich meinem Projekt folgende Verweise hinzufügen:

• C:\Program Files\Microsoft SQL Server\120\SDK\Assemblies\Microsoft.SqlServer.ConnectionInfo.dll
• C:\Program Files\Microsoft SQL Server\120\SDK\Assemblies\Microsoft.SqlServer.Smo.dll

Ich habe keine Ahnung, ob dies die richtigen DLLs sind, da sich in C: \ Programme \ Microsoft SQL Server mehrere Ordner befinden, aber in meiner Anwendung funktionieren diese beiden.

Ich habe es geschafft, die Antwort durch Lesen des Handbuchs herauszufinden :)

Dieser Auszug aus dem MSDN

Das Codebeispiel vermeidet eine Deadlock-Bedingung, indem p.StandardOutput.ReadToEnd vor p.WaitForExit aufgerufen wird. Eine Deadlock-Bedingung kann auftreten, wenn der übergeordnete Prozess p.WaitForExit vor p.StandardOutput.ReadToEnd aufruft und der untergeordnete Prozess genügend Text schreibt, um den umgeleiteten Stream zu füllen. Der übergeordnete Prozess würde unbegrenzt warten, bis der untergeordnete Prozess beendet wird. Der untergeordnete Prozess würde unbegrenzt darauf warten, dass der übergeordnete Prozess aus dem vollständigen StandardOutput-Stream liest.

Es gibt ein ähnliches Problem, wenn Sie den gesamten Text sowohl aus der Standardausgabe als auch aus den Standardfehlerströmen lesen. Der folgende C # -Code führt beispielsweise eine Leseoperation für beide Streams aus.

Verwandelt den Code in diesen;

Process p = new Process();
p.StartInfo.UseShellExecute = false;
p.StartInfo.RedirectStandardOutput = true;
p.StartInfo.FileName = "sqlplus";
p.StartInfo.Arguments = string.Format("xxx/xxx@{0} @{1}", in_database, s);

bool started = p.Start();
// important ... read stream input before waiting for exit.
// this avoids deadlock.
string output = p.StandardOutput.ReadToEnd();

p.WaitForExit();

Console.WriteLine(output);

if (p.ExitCode != 0)
{
    Console.WriteLine( string.Format("*** Failed : {0} - {1}",s,p.ExitCode));
    break;
}

Welches jetzt richtig beendet.

Es sind zwei Punkte zu beachten.

1) Dieser Quellcode hat bei mir funktioniert:

private static string Execute(string credentials, string scriptDir, string scriptFilename)
{ 
  Process process = new Process();
  process.StartInfo.UseShellExecute = false;
  process.StartInfo.WorkingDirectory = scriptDir;
  process.StartInfo.RedirectStandardOutput = true;
  process.StartInfo.FileName = "sqlplus";
  process.StartInfo.Arguments = string.Format("{0} @{1}", credentials, scriptFilename);
  process.StartInfo.CreateNoWindow = true;

  process.Start();
  string output = process.StandardOutput.ReadToEnd();
  process.WaitForExit();

  return output;
}

Ich habe das Arbeitsverzeichnis auf das Skriptverzeichnis gesetzt, damit auch Unterskripte innerhalb des Skripts funktionieren.

Nennen Sie es zB als Execute("usr/pwd@service", "c:\myscripts", "script.sql")

2) Sie müssen Ihr SQL-Skript mit der Anweisung abschließen EXIT;

Mit EntityFramework können Sie eine solche Lösung wählen. Ich benutze diesen Code, um e2e-Tests zu initialisieren. Um SQL-Injection-Angriffe zu verhindern, stellen Sie sicher, dass dieses Skript nicht basierend auf Benutzereingaben generiert wird, oder verwenden Sie hierfür Befehlsparameter (siehe Überladung von ExecuteSqlCommand, das Parameter akzeptiert).

public static void ExecuteSqlScript(string sqlScript)
{
    using (MyEntities dataModel = new MyEntities())
    {
        // split script on GO commands
        IEnumerable<string> commands = 
            Regex.Split(
                sqlScript, 
                @"^\s*GO\s*$",
                RegexOptions.Multiline | RegexOptions.IgnoreCase);

        foreach (string command in commands)
        {
            if (command.Trim() != string.Empty)
            {
                dataModel.Database.ExecuteSqlCommand(command);
            }
        }              
    }
}

Ich konnte keinen genauen und gültigen Weg finden, dies zu tun. Nach einem ganzen Tag kam ich mit diesem gemischten Code aus verschiedenen Quellen und versuchte, die Arbeit zu erledigen.

Es wird jedoch immer noch eine Ausnahme generiert ExecuteNonQuery: CommandText property has not been Initialized, obwohl die Skriptdatei erfolgreich ausgeführt wird. In meinem Fall wird die Datenbank erfolgreich erstellt und beim ersten Start werden Daten eingefügt.

public partial class Form1 : MetroForm
{
    SqlConnection cn;
    SqlCommand cm;
    public Form1()
    {
        InitializeComponent();
    }

    private void Form1_Load(object sender, EventArgs e)
    {
        if (!CheckDatabaseExist())
        {
            GenerateDatabase();
        }
    }

    private bool CheckDatabaseExist()
    {
        SqlConnection con = new SqlConnection(@"Data Source=.\SQLEXPRESS;Initial Catalog=SalmanTradersDB;Integrated Security=true");
        try
        {
            con.Open();
            return true;
        }
        catch
        {
            return false;
        }
    }

    private void GenerateDatabase()
    {

        try
        {
            cn = new SqlConnection(@"Data Source=.\SQLEXPRESS;Initial Catalog=master;Integrated Security=True");
            StringBuilder sb = new StringBuilder();
            sb.Append(string.Format("drop databse {0}", "SalmanTradersDB"));
            cm = new SqlCommand(sb.ToString() , cn);
            cn.Open();
            cm.ExecuteNonQuery();
            cn.Close();
        }
        catch
        {

        }
        try
        {
            //Application.StartupPath is the location where the application is Installed
            //Here File Path Can Be Provided Via OpenFileDialog
            if (File.Exists(Application.StartupPath + "\\script.sql"))
            {
                string script = null;
                script = File.ReadAllText(Application.StartupPath + "\\script.sql");
                string[] ScriptSplitter = script.Split(new string[] { "GO" }, StringSplitOptions.None);
                using (cn = new SqlConnection(@"Data Source=.\SQLEXPRESS;Initial Catalog=master;Integrated Security=True"))
                {
                    cn.Open();
                    foreach (string str in ScriptSplitter)
                    {
                        using (cm = cn.CreateCommand())
                        {
                            cm.CommandText = str;
                            cm.ExecuteNonQuery();
                        }
                    }
                }
            }
        }
        catch
        {

        }

    }

}