C# SQL klasse

Jeg har en lignende klasse jeg lige har stykket sammen fra mit arbejdskode (beklager hvis kommentarerne ikke er tilstrækkelige). Den bruger en anden tilgang til singleton som er lidt mere sikker - se evt. min artikel her på udvikleren omkring singletons. Den har desuden schemaQueries for at hente alle tabeller, kolonner, osv ud af databasen. Jeg mangler dog noget isoleret der kan eksekvere en insert fx ude at returnere noget. Men jeg indsætter aldrig i en database med min kode.

public class BetterSQLClass
{
    private SqlConnection conn;

    #region Singleton setup
    private static BetterSQLClass instance;

    private BetterSQLClass()
    {
        conn = new SqlConnection();
        conn.ConnectionString = "my connectionstring";
    }

    static BetterSQLClass()
    {
        //skjuler public constructor og instantierer statiske variable,
        //bliver kun kaldt een gang
        instance = new BetterSQLClass();
    }

    public static BetterSQLClass Instance
    {
        //returnerer instansen
        get { return instance; }
    }

    public static void Initialize(BetterSQLClass newInstance)
    {
        //bruges i unit tests, til at erstatte denne instans af singleton med en ny stub
        instance = newInstance;
    }
    #endregion   
 
    public virtual DataTable ExecuteSQL(string sql)
    {
        DataTable result = null;
        SqlCommand command = this.conn.CreateCommand();
        command.CommandText = sql;
        command.CommandType = CommandType.Text;
        try
        {
            conn.Open();
            SqlDataReader reader = command.ExecuteReader();
            result = ConvertReaderToDataTable(reader);
        }
        catch
        {

        }
        finally
        {
            if (this.conn.State == ConnectionState.Open)
            {
                this.conn.Close();
            }
        }
        return result;
    }

    public virtual DataTable ExecuteSQL(string sql, List<SqlParameter> parameters)
    {
        DataTable result = null;
        SqlCommand command = conn.CreateCommand();
        command.CommandText = sql;
        foreach (SqlParameter param in parameters)
        {
            command.Parameters.Add(param);
        }
        command.CommandType = CommandType.Text;
        try
        {
            conn.Open();
            SqlDataReader reader = command.ExecuteReader();
            result = ConvertReaderToDataTable(reader);
        }
        catch
        {

        }
        finally
        {
            if (conn.State == ConnectionState.Open)
            {
                conn.Close();
            }
        }
        return result;
    }

    public virtual DataTable ExecuteSchemaQuery(string collectionname)
    {
        return ExecuteSchemaQuery(collectionname, null);
    }

    public virtual DataTable ExecuteSchemaQuery(string collectionname, string[] restrictionValues)
    {
        DataTable result = null;
        try
        {
            if (conn.State == ConnectionState.Closed)
            {
                conn.Open();
            }
            result = conn.GetSchema(collectionname, restrictionValues);
        }
        catch
        {
            //GlobalsRegistry.XmlLog.LogException("Exception occurred executing a schema query", ex);
        }
        finally
        {
            conn.Close();
        }
        return result;
    }

    /// <summary>
    /// Converts the reader into an offline datatable, enabling the connection to the database to be closed immediately
    /// </summary>
    /// <param name="reader">The reader to convert</param>
    /// <returns>A datatable populated with data from the input parameter</returns>
    protected DataTable ConvertReaderToDataTable(SqlDataReader reader)
    {
        DataTable result = null;
        DataTable structureTable = reader.GetSchemaTable();
        result = new DataTable();
        foreach (DataRow row in structureTable.Rows)
        {
            result.Columns.Add(row["ColumnName"].ToString());
        }
        while (reader.Read())
        {
            DataRow dataRow = result.NewRow();
            for (int i = 0; i < result.Columns.Count; i++)
            {
                dataRow[i] = reader[i];
            }
            result.Rows.Add(dataRow);
        }
        return result;
    } 

}

Virtual gør at du kan nedarve og overskrive metoden i subklassen.

Hej Martin

Nu ved jeg ikke om det er et krav at du skal gøre sådan som du gør, men hvis du skal udnytte C# og dens måde at kommunikere på med en SQL Server, så vi jeg helt klart anbefale dig at anvende Linq To Sql.

Her vil du med 3-4 linjer kode kunne opnå det samme som dine 50-60 linjer + du slipper for de oldnordiske begreber med at cast/ convert

Det med Linq2Sql er en rigtig god idé og kaldene går også hurtigere end med "den gammeldags måde" som Martin har fat i. Men... Det er som bekendt ikke alle databaser som man kan bruge Linq2Sql til. Det kan kun bruges til MS SQL Server 2005, 2008 (så vidt jeg ved).

Det er som udgangspunkt en ganske udemærket måde din kode er lavet på Martin, men jeg vil anbefale at lave det til en abstrakt base-klasse, som andre database-klasser kan nedarve fra og så benytte denne til at lave specifikke klasser til forskellige databse-typer (MS SQL, MySql osv.). Det vil også lære dig en hel masse om at benytte abstrakte klasser

Tak Brian. Den giver nogle ideer til nogle forbedringer. Jeg kan se du bruger virtual ved nogle af metoderne. Hvad gør dette?

Jeg ved at en List er et dynamsk array, men er det mere korrekt end det jeg gør i min (bruger et string[,] array)?

Hvad med en metode der returnerede query resultatet som XML?

Jeg tror ikke der bliver brug for XML endnu, da vi endnu ikke har haft om det. Så jeg venter med at implementere det til jeg har fået undervisning i det.

Ok så forstår jeg det med virtual.

Ja, men jeg bruger denne metode, fordi vi har faget database og når det kobles sammen til et projekt, så skal vi også vise at vi kan lave avancerede queries.

Mht. det med at hente output fra en stored procedure så fandt jeg den her artikel (den er måske lidt gammel, men på den anden side så har det ikke ændret sig synderligt siden):
http://www.csharpfriends.com/articles/getarticle.aspx?articleid=78

Jeg har lavet nogle ændringer og nu ser min klasse således ud... inspireret af Brian.

 using System;
 using System.Collections.Generic;
 using System.Data;
 using System.Data.Sql;
 using System.Data.SqlClient;
 
 namespace Mssql
 {
     public class SqlClass
     {
         static SqlClass instance = null;
 
         DataTable dTable = null;
         SqlDataAdapter sqlAdapter = null;
         SqlConnection connection = null;
 
         private SqlClass()
         {
             connection = new SqlConnection();
         }
 
         public int NonQuery(string query)
         {
             SqlCommand sqlCommand = this.connection.CreateCommand();
             sqlCommand.CommandType = CommandType.Text;
             sqlCommand.CommandText = query;
             
             int rowsAffected = 0;
 
             try
             {
                 rowsAffected = sqlCommand.ExecuteNonQuery();
             }
             catch
             { }
             finally
             {
                 if (this.connection.State == ConnectionState.Open)
                     this.connection.Close();
             }
 
             return rowsAffected;
         }
 
         public string[,] ToArray()
         {
             string[,] data = new string[this.Columns, this.Rows];
 
             for(int i = 0; i < this.Columns; i++)
             {
                 for(int j = 0; j < this.Rows; j++)
                 {
                     data[i, j] = this.dTable.Rows[i][j].ToString();
                 }
             }
             return data;
         }
 
         public void Query(string query)
         {
             SqlCommand sqlCommand = this.connection.CreateCommand();
             sqlCommand.CommandType = CommandType.Text;
 
             try
             {
                 sqlCommand.CommandText = query;
 
                 this.dTable = new DataTable();
                 this.sqlAdapter = new SqlDataAdapter(sqlCommand);
                 this.sqlAdapter.Fill(this.dTable);
             }
             catch
             { }
             finally
             {
                 if (this.connection.State == ConnectionState.Open)
                     this.connection.Close();
             }
         }
 
         public void SetInfo(string dataSource, string catalog)
         {
             string connString = "Data Source=" + dataSource + "; Initial Catalog=" + catalog + "; Integrated Security=SSPI;";
 
             this.connection.ConnectionString = connString;
         }
 
         public void SetInfo(string dataSource, string catalog, string userId, string password)
         {
             string connString = "Data Source=" + dataSource + "; Initial Catalog=" + catalog + "; User ID=" + userId + "; Password=" + password + ";";
 
             this.connection.ConnectionString = connString;
         }
 
         public void StoredProcedure(string procedure, string[,] parameters)
         {
             SqlCommand sqlCommand = this.connection.CreateCommand();
             sqlCommand.CommandType = CommandType.StoredProcedure;
             sqlCommand.CommandText = procedure;
 
             for (int i = 0; i < parameters.GetLength(0); i++)
             {
                 SqlParameter sqlParam = new SqlParameter("@" + parameters[i, 0], parameters[i, 1]);
                 sqlCommand.Parameters.Add(sqlParam);
             }
 
             try
             {
                 this.dTable = new DataTable();
                 this.sqlAdapter = new SqlDataAdapter(sqlCommand);
                 this.sqlAdapter.Fill(this.dTable);
             }
             catch
             { }
             finally
             {
                 if (this.connection.State == ConnectionState.Open)
                     this.connection.Close();
             }
         }
 
         public DataTable Fetch()
         {
             return this.dTable;
         }
 
         public static SqlClass getInstance()
         {
             if (instance == null)
                 instance = new SqlClass();
             return instance;
         }
 
         public int Columns
         {
             get
             {
                 return this.dTable.Columns.Count;
             }
         }
 
         public int Rows
         {
             get
             {
                 return this.dTable.Rows.Count;
             }
         }
 
 
     }
 }

Andre ting som umidelbare mangler?

Jonas: Jeg kigger lige på det link