1 private static SqlConnection connection;
2 public static SqlConnection Connection
3 {
4 get
5 {
6 string connectionString = ConfigurationManager.ConnectionStrings["MyCommerce"].ConnectionString;
7 if (connection == null)
8 {
9 connection = new SqlConnection(connectionString);
10 connection.Open();
11 }
12 else if (connection.State == System.Data.ConnectionState.Closed)
13 {
14 connection.Open();
15 }
16 else if (connection.State == System.Data.ConnectionState.Broken)
17 {
18 connection.Close();
19 connection.Open();
20 }
21 return connection;
22 }
23 }
24
25
26
27
28 public static int ExecuteCommand(string safeSql)
29 {
30 SqlCommand cmd = new SqlCommand(safeSql, Connection);
31 int result = cmd.ExecuteNonQuery();
32 return result;
33 }
34
35 public static int ExecuteCommand(string sql, params SqlParameter[] values)
36 {
37 SqlCommand cmd = new SqlCommand(sql, Connection);
38 cmd.Parameters.AddRange(values);
39 return cmd.ExecuteNonQuery();
40 }
41
42 public static int GetScalar(string safeSql)
43 {
44 SqlCommand cmd = new SqlCommand(safeSql, Connection);
45 int result = Convert.ToInt32(cmd.ExecuteScalar());
46 return result;
47 }
48
49 public static int GetScalar(string sql, params SqlParameter[] values)
50 {
51 SqlCommand cmd = new SqlCommand(sql, Connection);
52 cmd.Parameters.AddRange(values);
53 int result = Convert.ToInt32(cmd.ExecuteScalar());
54 return result;
55 }
56
57 public static SqlDataReader GetReader(string safeSql)
58 {
59 SqlCommand cmd = new SqlCommand(safeSql, Connection);
60 SqlDataReader reader = cmd.ExecuteReader();
61 return reader;
62 }
63
64 public static SqlDataReader GetReader(string sql, params SqlParameter[] values)
65 {
66 SqlCommand cmd = new SqlCommand(sql, Connection);
67 cmd.Parameters.AddRange(values);
68 SqlDataReader reader = cmd.ExecuteReader();
69 return reader;
70 }
71
72 public static DataTable GetDataSet(string safeSql)
73 {
74 DataSet ds = new DataSet();
75 SqlCommand cmd = new SqlCommand(safeSql, Connection);
76 SqlDataAdapter da = new SqlDataAdapter(cmd);
77 da.Fill(ds);
78 return ds.Tables[0];
79 }
80
81 public static DataTable GetDataSet(string sql, params SqlParameter[] values)
82 {
83 DataSet ds = new DataSet();
84 SqlCommand cmd = new SqlCommand(sql, Connection);
85 cmd.Parameters.AddRange(values);
86 SqlDataAdapter da = new SqlDataAdapter(cmd);
87 da.Fill(ds);
88 return ds.Tables[0];
89 }
90
91 }
编辑器加载中...