C# SQLHelper

41824 단어 help
  1 class SQLHelper

  2     {

  3         #region     

  4         //      

  5         private SqlConnection con;

  6         /// <summary>

  7         ///           

  8         /// </summary>

  9         /// <returns></returns>

 10         public static String GetSqlConnection()

 11         {

 12             String conn = ConfigurationManager.AppSettings["connectionString"].ToString();

 13             return conn;

 14         }

 15         #endregion

 16         #region   sql   

 17         /// <summary>

 18         ///        SQL  

 19         /// </summary>

 20         /// <param name="Sqlstr"></param>

 21         /// <returns></returns>

 22         public static int ExecuteSql(String Sqlstr)

 23         {

 24             String ConnStr = GetSqlConnection();

 25             using (SqlConnection conn = new SqlConnection(ConnStr))

 26             {

 27                 SqlCommand cmd = new SqlCommand();

 28                 cmd.Connection = conn;

 29                 cmd.CommandText = Sqlstr;

 30                 conn.Open();

 31                 cmd.ExecuteNonQuery();

 32                 conn.Close();

 33                 return 1;

 34             }

 35         }

 36         /// <summary>

 37         ///       SQL  

 38         /// </summary>

 39         /// <param name="Sqlstr">SQL  </param>

 40         /// <param name="param">      </param>

 41         /// <returns></returns>

 42         public static int ExecuteSql(String Sqlstr, SqlParameter[] param)

 43         {

 44             String ConnStr = GetSqlConnection();

 45             using (SqlConnection conn = new SqlConnection(ConnStr))

 46             {

 47                 SqlCommand cmd = new SqlCommand();

 48                 cmd.Connection = conn;

 49                 cmd.CommandText = Sqlstr;

 50                 cmd.Parameters.AddRange(param);

 51                 conn.Open();

 52                 cmd.ExecuteNonQuery();

 53                 conn.Close();

 54                 return 1;

 55             }

 56         }

 57         /// <summary>

 58         ///   DataReader

 59         /// </summary>

 60         /// <param name="Sqlstr"></param>

 61         /// <returns></returns>

 62         public static SqlDataReader ExecuteReader(String Sqlstr)

 63         {

 64             String ConnStr = GetSqlConnection();

 65             SqlConnection conn = new SqlConnection(ConnStr);//  DataReader ,     using() 

 66             try

 67             {

 68                 SqlCommand cmd = new SqlCommand();

 69                 cmd.Connection = conn;

 70                 cmd.CommandText = Sqlstr;

 71                 conn.Open();

 72                 return cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);//     Connection

 73             }

 74             catch //(Exception ex)

 75             {

 76                 return null;

 77             }

 78         }

 79         /// <summary>

 80         ///   SQL        

 81         /// </summary>

 82         /// <param name="Sqlstr">SQL  </param>

 83         /// <returns></returns>

 84         public static DataTable ExecuteDt(String Sqlstr)

 85         {

 86             String ConnStr = GetSqlConnection();

 87             using (SqlConnection conn = new SqlConnection(ConnStr))

 88             {

 89                 SqlDataAdapter da = new SqlDataAdapter(Sqlstr, conn);

 90                 DataTable dt = new DataTable();

 91                 conn.Open();

 92                 da.Fill(dt);

 93                 conn.Close();

 94                 return dt;

 95             }

 96         }

 97         /// <summary>

 98         ///   SQL     DataSet

 99         /// </summary>

100         /// <param name="Sqlstr">SQL  </param>

101         /// <returns></returns>

102         public static DataSet ExecuteDs(String Sqlstr)

103         {

104             String ConnStr = GetSqlConnection();

105             using (SqlConnection conn = new SqlConnection(ConnStr))

106             {

107                 SqlDataAdapter da = new SqlDataAdapter(Sqlstr, conn);

108                 DataSet ds = new DataSet();

109                 conn.Open();

110                 da.Fill(ds);

111                 conn.Close();

112                 return ds;

113             }

114         }

115         #endregion

116         #region       

117         /// <summary>

118         ///       (   )

119         /// </summary>

120         /// <param name="procName">       </param>

121         /// <returns>        </returns>

122         public int RunProc(string procName)

123         {

124             SqlCommand cmd = CreateCommand(procName, null);

125             cmd.ExecuteNonQuery();

126             this.Close();

127             return (int)cmd.Parameters["ReturnValue"].Value;

128         }

129         /// <summary>

130         ///       (   )

131         /// </summary>

132         /// <param name="procName">       </param>

133         /// <param name="prams">           </param>

134         /// <returns>        </returns>

135         public int RunProc(string procName, SqlParameter[] prams)

136         {

137             SqlCommand cmd = CreateCommand(procName, prams);

138             cmd.ExecuteNonQuery();

139             this.Close();

140             return (int)cmd.Parameters[0].Value;

141         }

142         /// <summary>

143         ///       (   )

144         /// </summary>

145         /// <param name="procName">       </param>

146         /// <param name="dataReader">   </param>

147         public void RunProc(string procName, out SqlDataReader dataReader)

148         {

149             SqlCommand cmd = CreateCommand(procName, null);

150             dataReader = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);

151         }

152         /// <summary>

153         ///       (   )

154         /// </summary>

155         /// <param name="procName">       </param>

156         /// <param name="prams">           </param>

157         /// <param name="dataReader">   </param>

158         public void RunProc(string procName, SqlParameter[] prams, out SqlDataReader dataReader)

159         {

160             SqlCommand cmd = CreateCommand(procName, prams);

161             dataReader = cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);

162         }

163         /// <summary>

164         ///   Command          

165         /// </summary>

166         /// <param name="procName">       </param>

167         /// <param name="prams">           </param>

168         /// <returns>Command  </returns>

169         private SqlCommand CreateCommand(string procName, SqlParameter[] prams)

170         {

171             //         

172             Open();

173             //command = new SqlCommand( sprocName, new SqlConnection( ConfigManager.DALConnectionString ) );

174             SqlCommand cmd = new SqlCommand(procName, con);

175             cmd.CommandType = CommandType.StoredProcedure;

176             //              

177             if (prams != null)

178             {

179                 foreach (SqlParameter parameter in prams)

180                     cmd.Parameters.Add(parameter);

181             }

182             //   Command  

183             return cmd;

184         }

185         /// <summary>

186         ///       

187         /// </summary>

188         /// <param name="ParamName">   </param>

189         /// <param name="DbType">    </param>

190         /// <param name="Size">    </param>

191         /// <param name="Value">   </param>

192         /// <returns>     </returns>

193         public SqlParameter MakeInParam(string ParamName, SqlDbType DbType, int Size, object Value)

194         {

195             return MakeParam(ParamName, DbType, Size, ParameterDirection.Input, Value);

196         }

197         /// <summary>

198         ///       

199         /// </summary>

200         /// <param name="ParamName">   </param>

201         /// <param name="DbType">    </param>

202         /// <param name="Size">    </param>

203         /// <returns>     </returns>

204         public SqlParameter MakeOutParam(string ParamName, SqlDbType DbType, int Size)

205         {

206             return MakeParam(ParamName, DbType, Size, ParameterDirection.Output, null);

207         }

208         /// <summary>

209         ///         

210         /// </summary>

211         /// <param name="ParamName">   </param>

212         /// <param name="DbType">    </param>

213         /// <param name="Size">    </param>

214         /// <param name="Direction">     (  /  )</param>

215         /// <param name="Value">   </param>

216         /// <returns>     </returns>

217         public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)

218         {

219             SqlParameter param;

220             if (Size > 0)

221             {

222                 param = new SqlParameter(ParamName, DbType, Size);

223             }

224             else

225             {

226                 param = new SqlParameter(ParamName, DbType);

227             }

228             param.Direction = Direction;

229             if (!(Direction == ParameterDirection.Output && Value == null))

230             {

231                 param.Value = Value;

232             }

233             return param;

234         }

235         #endregion

236         #region         

237         /// <summary>

238         ///      

239         /// </summary>

240         private void Open()

241         {

242             //      

243             if (con == null)

244             {

245                 //      using System.Configuration;          

246                 con = new SqlConnection(GetSqlConnection());

247                 con.Open();

248             }

249         }

250         /// <summary>

251         ///      

252         /// </summary>

253         public void Close()

254         {

255             if (con != null)

256                 con.Close();

257         }

258         /// <summary>

259         ///      

260         /// </summary>

261         public void Dispose()

262         {

263             //        

264             if (con != null)

265             {

266                 con.Dispose();

267                 con = null;

268             }

269         }

270         #endregion

271     }

좋은 웹페이지 즐겨찾기