rendered paste bodyusing System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Text;
using CI.Utils;
using CI.Data.Interfaces;
using Microsoft.Practices.EnterpriseLibrary.Data;
namespace CI.Data
{
public class Common
{
public static DataSet ExecuteDataSet(string storedProc)
{
return ExecuteDataSet(storedProc, null);
}
public static DataSet ExecuteDataSet(string storedProc, params object[] args)
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
return _db.ExecuteDataSet(_cmd);
}
public static object ExecuteScalar(string storedProc)
{
return ExecuteScalar(storedProc, null);
}
public static object ExecuteScalar(string storedProc, params object[] args)
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
object _ret = _db.ExecuteScalar(_cmd);
return _ret;
}
public static void ExecuteNonQuery(string storedProc)
{
ExecuteNonQuery(storedProc, null);
}
public static void ExecuteNonQuery(string storedProc, params object[] args)
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
_db.ExecuteNonQuery(_cmd);
}
public static DbDataReader ExecuteReader(string storedProc)
{
return ExecuteReader(storedProc, null);
}
public static DbDataReader ExecuteReader(CommandType commandType, string query)
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
return (DbDataReader)_db.ExecuteReader(commandType, query);
}
public static DbDataReader ExecuteReader(string storedProc, params object[] args)
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);
return _reader;
}
public static T Populate<T>(bool singlePopulate, string storedProc) where T : IDbDataReaderPopulate, new()
{
return Populate<T>(singlePopulate, storedProc, null);
}
public static T Populate<T>(bool singlePopulate, string storedProc, params object[] args) where T : IDbDataReaderPopulate, new()
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);
T _item = default(T);
using (_reader)
{
if (_reader.Read())
{
_item = new T();
_item.IDbDataReaderPopulate(_reader);
}
}
return _item;
}
public static List<T> Populate<T>(string storedProc) where T : IDbDataReaderPopulate, new()
{
return Populate<T>(storedProc, null);
}
public static List<T> Populate<T>(string storedProc, params object[] args) where T : IDbDataReaderPopulate, new()
{
Database _db = DatabaseFactory.CreateDatabase("CIBackend");
DbCommand _cmd = null;
if (args != null)
_cmd = _db.GetStoredProcCommand(storedProc, args);
else
_cmd = _db.GetStoredProcCommand(storedProc);
_cmd.CommandTimeout = 200;
DbDataReader _reader = (DbDataReader)_db.ExecuteReader(_cmd);
List<T> _coll = new List<T>();
using (_reader)
{
while (_reader.Read())
{
T _item = new T();
_item.IDbDataReaderPopulate(_reader);
_coll.Add(_item);
}
}
return _coll;
}
}
}