Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class DbObject
- {
- protected SqlConnection myConnection;
- private string myConnectionString;
- public DbObject()
- {
- myConnectionString = "Data Source";
- myConnection = new SqlConnection(myConnectionString);
- }
- public string getConnectionSting()
- {
- return myConnectionString;
- }
- public int RunProcedure(string storedProcName, IDataParameter[] parameters, int rowsAffected)
- {
- int result = 0;
- myConnection.Open();
- SqlCommand command = BuildIntCommand(storedProcName, parameters);
- rowsAffected = command.ExecuteNonQuery();
- result = Convert.ToInt32(command.Parameters["ReturnValue"].Value);
- myConnection.Close();
- return result;
- }
- public SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters)
- {
- SqlDataReader returnReader = null;
- myConnection.Open();
- SqlCommand command = BuildQueryCommand(storedProcName, parameters);
- command.CommandType = CommandType.StoredProcedure;
- returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
- return returnReader;
- }
- public DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName)
- {
- DataSet dataSet = new DataSet();
- myConnection.Open();
- SqlDataAdapter sqlDA = new SqlDataAdapter();
- sqlDA.SelectCommand = BuildQueryCommand(storedProcName, parameters);
- sqlDA.Fill(dataSet, tableName);
- myConnection.Close();
- return dataSet;
- }
- public void RunProcedure(string storedProcName, IDataParameter[] parameters, DataSet dataSet, string tableName)
- {
- myConnection.Open();
- SqlDataAdapter sqlDA = new SqlDataAdapter();
- sqlDA.SelectCommand = BuildIntCommand(storedProcName, parameters);
- sqlDA.Fill(dataSet, tableName);
- myConnection.Close();
- }
- public string ConnectionString
- {
- get { return myConnectionString; }
- }
- private SqlCommand BuildIntCommand(string storedProcName, IDataParameter[] parameters)
- {
- SqlCommand command = BuildQueryCommand(storedProcName, parameters);
- SqlParameter parameter = new SqlParameter();
- var _with1 = parameter;
- _with1.ParameterName = "ReturnValue";
- _with1.DbType = DbType.Int16;
- _with1.Size = 4;
- _with1.Direction = ParameterDirection.ReturnValue;
- _with1.IsNullable = false;
- _with1.Precision = 0;
- _with1.Scale = 0;
- _with1.SourceColumn = string.Empty;
- _with1.SourceVersion = DataRowVersion.Default;
- _with1.Value = null;
- command.Parameters.Add(parameter);
- return command;
- }
- private SqlCommand BuildQueryCommand(string storedProcName, IDataParameter[] parameters)
- {
- SqlCommand command = new SqlCommand(storedProcName, myConnection);
- command.CommandType = CommandType.StoredProcedure;
- SqlParameter parameter = null;
- foreach (SqlParameter parameter_loopVariable in parameters)
- {
- parameter = parameter_loopVariable;
- command.Parameters.Add(parameter);
- }
- return command;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement