C#.NET und SQL Server: Transaktionen verwenden

Aufgabenstellung

Mehrere SQL Statements sollen atomar (ACID) ausgeführt werden.

Beispiel:
Ein Datenimport mit mehreren INSERT Statements und vorherigen DELETE auf eine existierende Tabelle: Während ein anderer Benutzer auf die Tabelle zugreift, sieht er nur die Daten die bereits importiert wurden. Dies kann über eine Transaktion atomar (wie das umlegen eines Schalters mit COMMIT) ausgeführt werden.

Manipulationen (z.B. auf ein Konto) mit mehreren Zugriffen unterschiedlicher User (konkurrierende Zugriffe) können zu falschen Beträgen auf dem Konto führen (Nebenläufigkeitsprobleme):
Bei mehreren SQL Kommandos, die sequenziell/hintereinander ausgeführt werden, soll sichergestellt werden das andere Benutzer keine Werte manipulieren, die zu einer falschen Weiterberechnung führen (siehe auch: Lost update und Dirty Read bei Datenbanken).

Vorgehensweise

Es existiert eine Klasse SqlTransaction, deren Instanz über die FactoryMethode .BeginTransaction(„SampleTransaction“); zugewiesen werden kann. Die Instanz kann anschließend einem Command zugwiesen werden, welches bis zum COMMIT (Schalter umlegen/alles übernehmen) Befehle an den SQL Server sendet.

Lösung

private static void ExecuteSqlTransaction(string connectionString)
{
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        connection.Open();

        SqlCommand command = connection.CreateCommand();
        SqlTransaction transaction;

        // Start a local transaction.
        transaction = connection.BeginTransaction("SampleTransaction");

        // Must assign both transaction object and connection
        // to Command object for a pending local transaction
        command.Connection = connection;
        command.Transaction = transaction;

        try
        {
            command.CommandText =
                "Insert into Region (RegionID, RegionDescription) "+
                "VALUES (100, 'Description')";
            command.ExecuteNonQuery();
            command.CommandText =
                "Insert into Region (RegionID, RegionDescription) "+
                 "VALUES (101, 'Description')";
            command.ExecuteNonQuery();

            // Attempt to commit the transaction.
            transaction.Commit();
            Console.WriteLine("Both records are written to database.");
        }
        catch (Exception ex)
        {
            Console.WriteLine("Commit Exception Type: {0}", ex.GetType());
            Console.WriteLine("  Message: {0}", ex.Message);

            // Attempt to roll back the transaction.
            try
            {
                transaction.Rollback();
            }
            catch (Exception ex2)
            {
                // This catch block will handle any errors that may have occurred
                // on the server that would cause the rollback to fail, such as
                // a closed connection.
                Console.WriteLine("Rollback Exception Type: {0}", ex2.GetType());
                Console.WriteLine("  Message: {0}", ex2.Message);
            }
        }
    }

Adobe Flex 3: mx:DataGrid in die Zwischenablage / Clipboard kopieren (z.B. für Excel)

Aufgabenstellung

Der Inhalt eines mx:DataGrid soll in die Zwischenablage kopiert werden, um ihn z.B. in Excel einzufügen.

Anmerkung: Für AdvancedDataGrid mit Baum siehe auch

Ansatz

Verwendung von System.setClipboard(…); und Iteration über den DataProvider.

Lösung

public function clipData( dg:DataGrid ):void
{
var totalExport:String = new String();
var colList:Array = new Array();
for(var i:int = 0; i < dg.columnCount; i++) { colList.push(dg.columns[i].dataField); totalExport += dg.columns[i].headerText + "\t"; } totalExport += "\r"; for(var yp:int = 0; yp < dg.dataProvider.length; yp++) { for(var xp:int = 0; xp < colList.length; xp++) { totalExport += dg.dataProvider[yp][colList[xp]] + "\t"; } totalExport += "\r"; } System.setClipboard(totalExport); Alert.show('Copied to clipboard, you can paste it now to excel...'); } [/javascript]

C#.NET: Eine Datei zeilenweise einlesen

Aufgabenstellung

Eine Datei wird geöffnet und mit einem Dateizeiger über diese iteriert. Das Einlesen von Strukturdateien (z.B. CSV-Dateien) soll somit ermöglicht werden.

Ansatz

Verwendung der Klasse StreamReader zum Öffnen der Datei und der Methoden ReadLine() um Zeile-für-Zeile einen String zu erhalten.

Lösung


// Pfad muss backslashes maskieren (doppelt)
string pfadZurDatei=
"C:\\meinOrdner\\datei.txt"; 

if (!File.Exists(pfadZurDatei))
{
    // Alternativ Console.Write() nutzen
    MessageBox.Show(
   "Die Datei existiert nicht! Bitte Datei wählen!",
    "Wots lous?");
}
else
{
    StreamReader sr = new StreamReader(pfadZurDatei);
    string inputLine = "";
    
    // Zeilenzahl (um beim Einlesen z.B. Zeilen zu skippen)
    int i=0;
    while ((inputLine = sr.ReadLine()) != null)
    {
        i++;
       // Zeile steht in inputLine... 
       // Es handelt sich um eine CSV Datei
       values = inputLine.Split(new Char[] { ';' });

       // Iteriere über jede Zelle der Zeile
       for(int j = 0; j < values.length; j++)
       {
          string eineZelle=values[j];
       }
    }
}

MS SQL Server und C#.NET: Textdatei per SQL Bulk Insert

Aufgabenstellung

Es wird eine perfomante (ohne Cursor-Iterationen) Möglichkeit gesucht um Textdateien per C#.NET in den Microsoft SQL Server zu importieren.

Ansatz

C# bietet eine Klassenbibliothek mit den Klassen SqlBulkCopy und SqlBulkCopyOptions, die bereits im SAP Stammdaten Importer Tool vorgestellt wurde, und dessen Quellcode im unteren Abschnitt des Artikel als Visual Studio 2005 Projekt zum download angeboten wird. Dieses Tool ermöglicht das einlesen von SE16-Downloaddateien mit ein paar Millionen Datensätzen in weniger als 2 Sekunden. Bei der herkömmlichen Methode, einer Cursor-Iteration, wird je INSERT-Statement ein Datenbankaufruf/Netzwerkzugriff durchgeführt. Dies ist nur nicht mehr notwendig.

Lösung

DataTable füllen


...
DataTable dataTable = new DataTable();
...
// Spaltenüberschriften zum Table hinzufügen (in einer Schleife befüllbar)
for (/*Schleife um die Spaltennamen einzulesen*/)
{
   // Die Anzahl der Columns muss = objects array sein
   dataTable.Columns.Add("SPALTENNAME");
}
...
// Definition des Zeilenarrays
ArrayList objects = new ArrayList();
...
while(/*Schleife um zeilenweise über Datei zu iterieren*/)
{
  ...
  for (/*Schleife um über Zellen der Zeile zu iterieren*/)
  {
     ...
     objects.Add(aktuellesZellenElementString);
     ...
  }
   ...
   // Hinzufügen des Datenelements, das die Zeilendaten hat
   dataTable.Rows.Add(objects.ToArray());
}
...


DataTable in den MS SQL Server importieren


private void WriteToDatabase()
{
    // get your connection string
    string connString = msSqlServerString;
    // connect to SQL
    using (SqlConnection connection =  new SqlConnection(connString))
    {
        // make sure to enable triggers
        // more on triggers in next post

        SqlBulkCopy bulkCopy = new SqlBulkCopy
        (
            connection,
            SqlBulkCopyOptions.TableLock |
            SqlBulkCopyOptions.FireTriggers |
            SqlBulkCopyOptions.UseInternalTransaction,
            null
         );

        // set the destination table name
        bulkCopy.DestinationTableName = txtImportTable.Text;
        connection.Open();

        // write the data in the "dataTable"
        try
        {
            bulkCopy.WriteToServer(dataTable);
        }
        catch (Exception e)
        {
            MessageBox.Show("Es ist ein Fehler aufgetreten. "+
            "Stellen Sie sicher dass der Timeout im SQL Server "+
            "auf unendlich steht und AutoClose für die Verbindung "+
            "nicht aktiviert wurde. " + e.Message, "Fehler!");
        }
        connection.Close();
    }
    // reset
    this.dataTable.Clear();
}

Ein komplettes Beispiel lässt sich hier downloaden:
Quellcode SAP Stammdaten Importer (VS 2005 Projekt)

C#.NET: LDAP Zugriff

Aufgabenstellung

In größeren Firmen kann über das LDAP-Protkoll auf Personendaten und -informationen zugegriffen werden. Die kann z.B. für eine Authentifizierung per Singlesignon genutzt werden.

Ansatz

Möchte man diesen Dienst nutzen, muss man zunächst wissen auf welchem Server im Unternehmen ein solcher Dienst angeboten wird. Dies könnte z.B. ein Active Directory Server (Windows Server) oder ein Lotus Notes Server (notesldap) sein.

Zunächst benötigt man den Import:

using System.DirectoryServices;

Lösung

private void button1_Click(object sender, EventArgs e)
{
    DirectoryEntry DirEntry = new DirectoryEntry();
    {
        DirEntry.Path = "LDAP://notesldap.it.company.com";
        DirEntry.AuthenticationType = AuthenticationTypes.ServerBind;
    }
    Console.WriteLine(DirEntry.Name);

    DirectorySearcher search = new DirectorySearcher(DirEntry);
    {
        // Tweak this to refine your search
        search.Filter = "(sn=Karpenstein)";
        // I limit my results while I tweak          
        search.SearchScope = SearchScope.Subtree;
    }
    try
    {
        foreach (SearchResult result in search.FindAll())
        {
            if (result != null)
            {
                DirectoryEntry de = result.GetDirectoryEntry();
                textBox1.Text += "===================================="+br();
                textBox1.Text +=
                "User: \t\t" + de.Properties["uid"].Value.ToString() + br() +
                "objectclass:\t\t" + de.Properties["objectclass"].Value.ToString();

                IDictionaryEnumerator ide = de.Properties.GetEnumerator();
                ide.Reset();

                try
                {
                    while (ide.MoveNext())
                    {
                        PropertyValueCollection pvc = ide.Entry.Value as 
                                               PropertyValueCollection;

                        textBox1.Text += ide.Entry.Key.ToString();
                        textBox1.Text += pvc.Value;
                    }
                }
                catch (Exception sdf)
                {
                    textBox1.Text += sdf.Message;
                }
                
                //textBox1.Text += "location:\t\t" + de.Properties["location"].
                                              Value.ToString() + br();
                //textBox1.Text += "maildomain:\t\t" + de.Properties["maildomain"].
                                              Value.ToString() + br();

                textBox1.Text += "sn:\t\t" + de.Properties["sn"].
                                            Value.ToString() + br();
                //textBox1.Text += "dominocertificate:\t\t" + 
                    de.Properties["dominocertificate"].
                                             Value.ToString() + br();
                textBox1.Text += "mail:\t\t" + de.Properties["mail"].
                                             Value.ToString() + br();
                textBox1.Text += "l:\t\t" + de.Properties["l"].
                                            Value.ToString() + br();
                textBox1.Text += "displayname:\t\t" + de.Properties["displayname"].
                                            Value.ToString() + br();
                textBox1.Text += "givenname:\t\t" + de.Properties["givenname"].
                                           Value.ToString() + br();
                //textBox1.Text += "dc:\t\t" + de.Properties["dc"].
                                           Value.ToString() + br();
                //textBox1.Text += "dn:\t\t" + de.Properties["dn"].
                                           Value.ToString() + br();
                textBox1.Text += "cn:\t\t" + de.Properties["cn"].
                                            Value.ToString() + br();
                textBox1.Text += "====================================";
            }
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message.ToString());
    }
    finally
    {
        search.Dispose();
        DirEntry.Close();
    }
}

SAP Enterprise Portal: Deeplinks zu einer Portalseite

Problem

Möchte man eine Seite mit einem iView aufrufen, ist es meistens nötig die komplette Navigation bis zu diesem durchzuklicken. Das Portal besteht bei der Verwendung von iViews aus Frames.

Ansatz

Möchte man das SAP Enterprise Portal anweisen ein spezielles iView/eine spezielle Seite über einen Deeplink in den Frame zu laden, kann der folgende Trick genutzt werden.

Lösung

  1. Zunächst geht man auf die Portalseite, für die ein Deeplink benötight wird
  2. Zu die Adressleiste vom Browser gibt man javascript:void(prompt(„“,nodeid)); ein
  3. Der Deeplink setzt sich folgendermaßen zusammen: http://<hostname>:<port>/irj/portal?NavigationTarget=<javascript-result>

iView-Entwickler können den folgenden Code benutzen um Parameter über diesen Deeplink zu übergeben:

URL: http://firmenportalrechner.com:50000/irj/portal?NavigationTarget=navurl://885a76f8628af28c18d76773f98eaaaf&materialId=9380027

Java (z.B. iView): String materialId = (String) getPortalRequest().getServletRequest().getParameter(„materialId“);