Advertisement
Guest User

Untitled

a guest
Jul 31st, 2016
63
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.17 KB | None | 0 0
  1. public class DbObject
  2.  
  3. {
  4.  
  5. protected SqlConnection myConnection;
  6.  
  7. private string myConnectionString;
  8.  
  9. public DbObject()
  10. {
  11. myConnectionString = "Data Source";
  12. myConnection = new SqlConnection(myConnectionString);
  13. }
  14.  
  15. public string getConnectionSting()
  16. {
  17. return myConnectionString;
  18. }
  19. public int RunProcedure(string storedProcName, IDataParameter[] parameters, int rowsAffected)
  20. {
  21. int result = 0;
  22. myConnection.Open();
  23. SqlCommand command = BuildIntCommand(storedProcName, parameters);
  24. rowsAffected = command.ExecuteNonQuery();
  25. result = Convert.ToInt32(command.Parameters["ReturnValue"].Value);
  26. myConnection.Close();
  27. return result;
  28. }
  29.  
  30. public SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters)
  31. {
  32. SqlDataReader returnReader = null;
  33.  
  34. myConnection.Open();
  35. SqlCommand command = BuildQueryCommand(storedProcName, parameters);
  36. command.CommandType = CommandType.StoredProcedure;
  37. returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
  38.  
  39. return returnReader;
  40. }
  41.  
  42. public DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName)
  43. {
  44. DataSet dataSet = new DataSet();
  45.  
  46. myConnection.Open();
  47. SqlDataAdapter sqlDA = new SqlDataAdapter();
  48. sqlDA.SelectCommand = BuildQueryCommand(storedProcName, parameters);
  49. sqlDA.Fill(dataSet, tableName);
  50. myConnection.Close();
  51. return dataSet;
  52. }
  53. public void RunProcedure(string storedProcName, IDataParameter[] parameters, DataSet dataSet, string tableName)
  54. {
  55. myConnection.Open();
  56. SqlDataAdapter sqlDA = new SqlDataAdapter();
  57. sqlDA.SelectCommand = BuildIntCommand(storedProcName, parameters);
  58. sqlDA.Fill(dataSet, tableName);
  59. myConnection.Close();
  60.  
  61. }
  62.  
  63.  
  64. public string ConnectionString
  65. {
  66. get { return myConnectionString; }
  67. }
  68.  
  69. private SqlCommand BuildIntCommand(string storedProcName, IDataParameter[] parameters)
  70. {
  71. SqlCommand command = BuildQueryCommand(storedProcName, parameters);
  72. SqlParameter parameter = new SqlParameter();
  73.  
  74. var _with1 = parameter;
  75. _with1.ParameterName = "ReturnValue";
  76. _with1.DbType = DbType.Int16;
  77. _with1.Size = 4;
  78. _with1.Direction = ParameterDirection.ReturnValue;
  79. _with1.IsNullable = false;
  80. _with1.Precision = 0;
  81. _with1.Scale = 0;
  82. _with1.SourceColumn = string.Empty;
  83. _with1.SourceVersion = DataRowVersion.Default;
  84. _with1.Value = null;
  85. command.Parameters.Add(parameter);
  86.  
  87. return command;
  88. }
  89.  
  90.  
  91.  
  92. private SqlCommand BuildQueryCommand(string storedProcName, IDataParameter[] parameters)
  93. {
  94. SqlCommand command = new SqlCommand(storedProcName, myConnection);
  95. command.CommandType = CommandType.StoredProcedure;
  96.  
  97. SqlParameter parameter = null;
  98. foreach (SqlParameter parameter_loopVariable in parameters)
  99. {
  100. parameter = parameter_loopVariable;
  101. command.Parameters.Add(parameter);
  102. }
  103.  
  104. return command;
  105. }
  106.  
  107. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement