{C#} - Kleine Klasse zum Datenbankhandling

[F1r3st0rm]

Hoi,

ich hab vor einiger Zeit mal eine kleine Klasse zum Datenbankhandling geschrieben, welche ich gerne mit euch Teilen möchte. Ihr könnt Sie gerne verwenden, auch ohne Namensnennung, allerdings bitte ich euch, Sie nicht für Kommerzielle Systeme zu verwenden.

Hauptklasse:
[src=csharp]
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MyNamespace
{
public abstract class SqlBaseSystem<T>
{
public abstract string GetSPName();
public abstract List<SqlParameter> GetParameters();
public abstract string GetSaveSPName();
public abstract List<SqlParameter> GetSaveParameters();

private SqlConnection _Connection = new SqlConnection(@"HIER DEN CONNECTIONSTRING REIN");

public T StartQuery()
{
T result = default(T);
using (SqlCommand command = new SqlCommand(this.GetSPName(), this._Connection))
{
try
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(this.GetParameters().ToArray());

this._Connection.Open();

SqlDataReader reader = command.ExecuteReader();

while (reader.HasRows && reader.Read())
result = (T)Activator.CreateInstance(typeof(T), new object[] { reader });

this._Connection.Close();
return result;
}
catch (Exception e)
{
this._Connection.Close();

throw new Exception(e.Message, e.InnerException);
}

}
}

public T StartQuery(Dictionary<string, object> parameters)
{
T result = default(T);
using (SqlCommand command = new SqlCommand(this.GetSPName(), this._Connection))
{
try
{
command.CommandType = CommandType.StoredProcedure;
foreach (KeyValuePair<string, object> item in parameters)
command.Parameters.AddWithValue(item.Key, item.Value);

this._Connection.Open();

SqlDataReader reader = command.ExecuteReader();

while (reader.HasRows && reader.Read())
result = (T)Activator.CreateInstance(typeof(T), new object[] { reader });

this._Connection.Close();
return result;
}
catch (Exception e)
{
this._Connection.Close();

throw new Exception(e.Message, e.InnerException);
}
}
}

public List<T> StartQueryWithMultiResult()
{
List<T> result = new List<T>();
using (SqlCommand command = new SqlCommand(this.GetSPName(), this._Connection))
{
try
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(this.GetParameters().ToArray());

this._Connection.Open();

SqlDataReader reader = command.ExecuteReader();

while (reader.HasRows && reader.Read())
result.Add((T)Activator.CreateInstance(typeof(T), new object[] { reader }));

this._Connection.Close();
return result;
}
catch (Exception e)
{
this._Connection.Close();

throw new Exception(e.Message, e.InnerException);
}
}
}

public List<T> StartQueryWithMultiResult(Dictionary<string, object> parameters)
{
List<T> result = new List<T>();
using (SqlCommand command = new SqlCommand(this.GetSPName(), this._Connection))
{
try
{
command.CommandType = CommandType.StoredProcedure;
foreach (KeyValuePair<string, object> item in parameters)
command.Parameters.AddWithValue(item.Key, item.Value);

this._Connection.Open();

SqlDataReader reader = command.ExecuteReader();

while (reader.HasRows && reader.Read())
result.Add((T)Activator.CreateInstance(typeof(T), new object[] { reader }));

this._Connection.Close();
return result;

}
catch (Exception e)
{
this._Connection.Close();

throw new Exception(e.Message, e.InnerException);
}
}
}

public void Save()
{
using (SqlCommand command = new SqlCommand(this.GetSaveSPName(), this._Connection))
{
try
{
command.CommandType = CommandType.StoredProcedure;
command.Parameters.AddRange(this.GetSaveParameters().ToArray());

this._Connection.Open();
command.ExecuteNonQuery();
this._Connection.Close();
}
catch (Exception e)
{
this._Connection.Close();

throw new Exception(e.Message, e.InnerException);
}
}
}
}
}
[/src]

Ganz ohne Hilfe funktioniert diese Klasse aber nicht. Da ich aber nicht wollte, das die Klasse sich selbst implementieren muss, habe ich eine kleine Hilfsklasse geschrieben:

[src=csharp]
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MyNamespace
{
class InstanceManager<T>
{
public static T GetClearObject()
{
return (T)Activator.CreateInstance(typeof(T));
}
}
}
[/src]

Eine Instanz könnt ihr dann mit folgendem Code erzeugen:
[src=csharp]

Beispiel beispiel = InstanceManager<Beispiel>.GetClearObject();
beispiel = beispiel.StartQuery(); //Alternativ kann auch eine Liste vom Typ SqlParameter als Parameter übergeben werden.

[/src]

Eine Modelklasse in welcher die ausgelesenen Daten gespeichert werden sollen kann beispielsweise so aussehen:
[src=csharp]
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace MyNamespace
{
public class User : SqlBaseSystem<User>
{
public Int64 ID { get; set; }
public string UserName { get; set; }
public Address Adress { get; set; }
public Contact Contact { get; set; }
public Group UserGroup { get; set; }

public User(IDataRecord data)
{
this.ID = (Int64)data["ID"];
this.UserName = data["Username"].ToString();
this.Adress = new Address(data);
this.Contact = new Contact(data);
this.UserGroup = new Group(data);

if (this.ID == (Int64)data["GroupLeader"])
this.UserGroup.IsGroupLeader = true;
else
this.UserGroup.IsGroupLeader = false;
}

public User() { }

public override string GetSPName()
{
return "p_GetUserDataByUsernameAndPassword";
}

public override List<SqlParameter> GetParameters()
{
throw new NotImplementedException();
}

public override string GetSaveSPName()
{
throw new NotImplementedException();
}

public override List<SqlParameter> GetSaveParameters()
{
throw new NotImplementedException();
}
}

}[/src]

Die Klasse müsste sich eigentlich auch ohne Kommentare selbst erklären. Wenn ihr aber Hilfe braucht, fragt mich einfach. Ich versuche euch so gut ich kann zu helfen.

Kleinen Hinweis noch. Das ganze System funktioniert ausschließlich mit MSSQL als Datenbanksystem und ihr müsst mit Gespeicherten Prozeduren arbeiten.

Wenn ihr die Daten verändert könnt ihr das ganze in die Datenbank zurückspeichern indem ihr die Methode Save() verwendet. Allerdings muss natürlich auch dafür eine Gespeicherte Prozedur angelegt werden.