Forum
Aktif konular
Üyeler
Kurallar
Arama
C# Veritabanı Bağlantı Klasları C# Veritabanı Bağlantı Klasları
-
Aslında nett kütüphaneler var fakat ben kendim yazmayı tercih ediyorum.Sürekli kullandığım iki klası sizlerle paylaşmak istedim.Derlemedim isterseniz değiştrirsiniz diye.
iki klas dan biri access diğeri sql için.
sql de procedure için hazırladım ve addparameters metodunda parametre adı ve value si
oledb de ise parametrler '?' işaretine göre hazırlandı.Yani
Veri ver = new Veri();
ver.CmdText = "select * ftom tablo where id = ?";
ver.AddParameters(1);
şeklinde
/////////////////////////////////////////////////SQL///////////////////////////////////////////////////
using System;
using System.Data;
using System.Configuration;
using System.Linq;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.HtmlControls;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Xml.Linq;
using System.Collections.Generic;
using System.Data.SqlClient;/// <summary>
/// cmdexe
/// </summary>
public class Veri
{
private string _Baglanti;
public Veri()
{
_Baglanti = ConfigurationManager.AppSettings["Baglanti"];
}
private List<object> Values = new List<object>();
private List<string> Params = new List<string>();
public void AddParameters(string param, object val)
{
Values.Add(val);
Params.Add(param);
}private SqlConnection _Con;
private SqlConnection Con
{
get
{
if (_Con == null)
_Con = new SqlConnection(_Baglanti);
return _Con;
}
}
private string _CmdText;public string CmdText
{
get { return _CmdText; }
set { _CmdText = value; }
}
private SqlCommand _Cmd;
private SqlCommand Cmd
{
get
{
if (_Cmd == null)
{
_Cmd = new SqlCommand();
_Cmd.Connection = Con;
_Cmd.CommandType = CommandType.StoredProcedure;
}
if (Values.Count > 0)
{
for (int i = 0; i < Values.Count; i++)
{
_Cmd.Parameters.AddWithValue(Params[i], Values[i]);
}
}
_Cmd.CommandText = _CmdText;
return _Cmd;
}
}
public int NonQuery
{
get
{
Con.Open();
int donen = Cmd.ExecuteNonQuery();
Con.Close();
return donen;
}
}public object Scalar
{
get
{
Con.Open();
object donen = Cmd.ExecuteScalar();
Con.Close();
return donen;
}
}
public IDataReader Reader
{
get
{
Con.Open();
IDataReader donen = Cmd.ExecuteReader(CommandBehavior.CloseConnection);
return donen;
}
}
private SqlDataAdapter _Adapter;private SqlDataAdapter Adapter
{
get
{
if (_Adapter == null)
_Adapter = new SqlDataAdapter(Cmd);
return _Adapter;
}
}
public DataSet Source
{
get
{
DataSet set = new DataSet();
Adapter.Fill(set);
return set;
}
}
}////////////////////////////////////ACCESS/////////////////////////////////////////////////////////
using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.HtmlControls;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Data.OleDb;
using System.Collections.Generic;/// <summary>
/// cmdexe
/// </summary>
public class Veri
{
private string _Baglanti;
public Veri()
{
_Baglanti = ConfigurationManager.AppSettings["Baglanti"];
}
private List<object> Values = new List<object>();
public void AddParameters(object val)
{
Values.Add(val);
}private OleDbConnection _Con;
private OleDbConnection Con
{
get
{
if (_Con == null)
_Con = new OleDbConnection(_Baglanti);
return _Con;
}
}
private string _CmdText;public string CmdText
{
get { return _CmdText; }
set { _CmdText = value; }
}
private OleDbCommand _Cmd;
private OleDbCommand Cmd
{
get
{
if (_Cmd == null)
{
_Cmd = new OleDbCommand();
_Cmd.Connection = Con;
_Cmd.CommandType = CommandType.Text;
}
if (Values.Count > 0)
{
for(int i=0;i<Values.Count;i++)
{
_Cmd.Parameters.AddWithValue("?",Values[i]);
}
}
_Cmd.CommandText = _CmdText;
return _Cmd;
}
}
public int NonQuery
{
get
{
Con.Open();
int donen = Cmd.ExecuteNonQuery();
Con.Close();
return donen;
}
}public object Scalar
{
get
{
Con.Open();
object donen = Cmd.ExecuteScalar();
Con.Close();
return donen;
}
}
public IDataReader Reader
{
get
{
Con.Open();
IDataReader donen = Cmd.ExecuteReader(CommandBehavior.CloseConnection);
return donen;
}
}
private OleDbDataAdapter _Adapter;private OleDbDataAdapter Adapter
{
get
{
if (_Adapter == null)
_Adapter = new OleDbDataAdapter(Cmd);
return _Adapter;
}
}
public DataSet Source
{
get
{
DataSet set = new DataSet();
Adapter.Fill(set);
return set;
}
}
} -
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace Get_Data
{
using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
public class DBClass
{
private static DBClass defaultInsatance = new DBClass();
public static DBClass Default
{
get { return defaultInsatance; }
}
public DBClass()
{
connectionStr = @"Data Source=PC;Initial Catalog=MovieBase;Integrated Security=True";
}
public bool InsertCommand(string queryStr)
{
SqlConnection cnn = new SqlConnection(connectionStr);
try
{
cnn.Open();
}
catch
{
return false;
}
try
{
SqlCommand insert = new SqlCommand(queryStr, cnn);
insert.ExecuteNonQuery();
cnn.Close();
}
catch (Exception ex)
{
return false;
}
return true;
}
public bool UpdateCommand(String updateCommand)
{
SqlConnection cnn = new SqlConnection(connectionStr);
try
{
cnn.Open();
}
catch
{
return false;
}
try
{
SqlCommand update = new SqlCommand(updateCommand, cnn);
update.ExecuteNonQuery();
cnn.Close();
}
catch
{
return false;
}
return true;
}
public DataSet SelectCommand(string queryStr)
{
SqlConnection cnn = new SqlConnection(connectionStr);
try
{
cnn.Open();
}
catch (Exception ex)
{
cnn.Close();
return null;
}
try
{
DataSet tempSet = new DataSet();
SqlDataAdapter selectAdapter = new SqlDataAdapter(queryStr, cnn);
selectAdapter.Fill(tempSet);
return tempSet;
}
catch
{
cnn.Close();
return null;
}
finally
{
cnn.Close();
}
}
public bool DeleteCommand(string queryStr)
{
SqlConnection cnn = new SqlConnection(connectionStr);
try
{
cnn.Open();
}
catch
{
return false;
}
try
{
SqlCommand insert = new SqlCommand(queryStr, cnn);
insert.ExecuteNonQuery();
cnn.Close();
}
catch
{
cnn.Close();
return false;
}
return true;
}
public bool ExecuteCommand(string queryStr)
{
SqlConnection cnn = new SqlConnection(connectionStr);
try
{
cnn.Open();
}
catch
{
if (cnn.State == ConnectionState.Open) cnn.Close();
return false;
}
try
{
SqlCommand command = new SqlCommand(queryStr, cnn);
command.ExecuteNonQuery();
cnn.Close();
}
catch
{
return false;
}
return true;
}
string connectionStr;
}
}/*Kullanım
query = "SELECT * from y .........";
DataSet xSet = DBClass.Default.SelectCommand(query);
string str = xSet.Tables[0].Rows[i][j];
*/
Kısayol
Şikayet
Özel Mesaj
Alıntı yap
Cevapla