Guest User

Untitled

a guest
Jan 21st, 2019
94
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 4.04 KB | None | 0 0
  1. private static void ReadOrderData(string connectionString)
  2. {
  3. string queryString = "SELECT OrderID, CustomerID FROM dbo.Orders;";
  4. using (SqlConnection connection = new SqlConnection(connectionString))
  5. {
  6. SqlCommand command = new SqlCommand(queryString, connection);
  7. connection.Open();
  8. SqlDataReader reader = command.ExecuteReader();
  9. try
  10. {
  11. while (reader.Read())
  12. {
  13. Console.WriteLine(String.Format("{0}, {1}", reader[0], reader[1]));
  14. }
  15. }
  16. finally
  17. {
  18. reader.Close();
  19. }
  20. }
  21. }
  22.  
  23. private SQLConnection CreateConnection()
  24. {
  25. var connection = new SqlConnection(_connectionString);
  26. connection.Open();
  27. return connection;
  28. }
  29.  
  30. private List<int> ReadOrderData()
  31. {
  32. using(var connection = CreateConnection())
  33. using(var command = connection.CreateCommand())
  34. {
  35. command.CommandText = "SELECT OrderID FROM dbo.Orders;";
  36.  
  37. using(var reader = command.ExecuteReader())
  38. {
  39. var results = new List<int>();
  40. while(reader.Read()) results.Add(reader.GetInt32(0));
  41. return results;
  42. }
  43. }
  44. }
  45.  
  46. using (var conn = new SqlConnection(cs))
  47. {
  48. var dogs = connection.Query("select name, age from dogs");
  49.  
  50. foreach (dynamic dog in dogs)
  51. {
  52. Console.WriteLine("{0} age {1}", dog.name, dog.age);
  53. }
  54. }
  55.  
  56. using (var conn = new SqlConnection(cs))
  57. {
  58. var dogs = connection.Query<Dog>("select Name, Age from dogs");
  59.  
  60. foreach (Dog dog in dogs)
  61. {
  62. Console.WriteLine("{0} age {1}", dog.Name, dog.Age);
  63. }
  64. }
  65.  
  66. class Dog
  67. {
  68. public string Name { get; set; }
  69. public int Age { get; set; }
  70. }
  71.  
  72. public void ExecuteWithDataReader(string sql, Action<DataReader> stuffToDo) {
  73. using (SqlConnection connection = new SqlConnection(connectionString)) {
  74. using (SqlCommand command = new SqlCommand(sql, connection)) {
  75. connection.Open();
  76.  
  77. using (SqlDataReader reader = command.ExecuteReader()) {
  78. try {
  79. while (reader.Read()) {
  80. stuffToDo(reader);
  81. }
  82. }
  83. finally {
  84. reader.Close();
  85. }
  86. }
  87. }
  88. }
  89. }
  90.  
  91.  
  92. private static void ReadOrderData(string connectionString) {
  93. string sql = "SELECT OrderID, CustomerID FROM dbo.Orders;";
  94.  
  95. ExecuteWithDataReader(sql, r => Console.WriteLine(String.Format("{0}, {1}", r[0], r[1])));
  96. }
  97.  
  98. private List<int> ReadOrderData()
  99. {
  100. return ExecuteList<int>("SELECT OrderID FROM dbo.Orders;",
  101. x => x.GetInt32("orderId")).ToList();
  102. }
  103.  
  104. private IEnumerable<T> ExecuteList(string query,
  105. Func<IDataRecord, T> entityCreator)
  106. {
  107. using(var connection = CreateConnection())
  108. using(var command = connection.CreateCommand())
  109. {
  110. command.CommandText = query;
  111. connection.Open();
  112. using(var reader = command.ExecuteReader())
  113. {
  114. while(reader.Read())
  115. yield return entityCreator(reader);
  116. }
  117. }
  118. }
  119.  
  120. using(var db = new MyDataContext())
  121. {
  122. var items = db.Orders.Select(item => new { item.OrderID, item.CustomerID })
  123. .ToList();
  124. items.ForEach(item => Console.WriteLine("{0} {1}", item.OrderID, item.CustomerID);
  125. }
  126.  
  127. using(conn = new sqlconnection)
  128. using(cmd = new sqlcommand) {
  129. // blah blah blah
  130. }
  131.  
  132. private SQLConnection CreateConnection()
  133. {
  134. var connection = new SqlConnection(_connectionString);
  135. connection.Open();
  136. return connection;
  137. }
  138.  
  139. public static DataTable StatisticsGet( Guid tenantId ) {
  140. DataTable result = new DataTable();
  141. result.Locale = CultureInfo.CurrentCulture;
  142.  
  143. Database db = DatabaseFactory.CreateDatabase(DatabaseType.Clients.ToString());
  144.  
  145. using (DbCommand dbCommand = db.GetStoredProcCommand("reg.StatsGet")) {
  146. db.AddInParameter(dbCommand, "TenantId", DbType.Guid, tenantId);
  147.  
  148. result.Load(db.ExecuteReader(dbCommand));
  149. } // using dbCommand
  150.  
  151. return result;
  152. } // method::StatisticsGet
Add Comment
Please, Sign In to add comment