学步园

using System;<br /> using System.Data;<br /> using System.Data.SqlClient;<br /> using System.Collections;</p> <p>namespace ReCard<br /> {<br /> public static class DB<br /> {</p> <p> private static SqlConnection connection = null;<br /> private static SqlCommand command = null;<br /> private static SqlDataAdapter adapter = null;<br /> private static string errorString;<br /> public static string ErrorString<br /> {<br /> get { return errorString; }<br /> }</p> <p> /// <summary><br /> /// 初始化<br /> /// </summary><br /> public static void Init(string ConnectionString)<br /> {<br /> connection = new SqlConnection(ConnectionString);<br /> command = connection.CreateCommand();<br /> adapter = new SqlDataAdapter();<br /> adapter.SelectCommand = command;<br /> }</p> <p> /// <summary><br /> /// 打开连接<br /> /// </summary><br /> /// <returns></returns><br /> public static bool Connect()<br /> {<br /> try<br /> {<br /> if (connection.State == ConnectionState.Closed)<br /> {<br /> connection.Open();<br /> }<br /> return true;<br /> }<br /> catch (Exception)<br /> {<br /> return false;<br /> }<br /> }</p> <p> /// <summary><br /> /// 关闭连接<br /> /// </summary><br /> /// <returns></returns><br /> public static bool CloseConnect()<br /> {<br /> try<br /> {<br /> if (connection.State == ConnectionState.Open)<br /> {<br /> connection.Close();<br /> }<br /> return true;<br /> }<br /> catch (Exception)<br /> {<br /> return false;<br /> }<br /> }</p> <p> /// <summary><br /> /// 根据查询语句从数据库检索数据<br /> /// </summary><br /> /// <param name="strSelect">查询语句</param><br /> /// <returns>有数据则返回DataTable对象，否则返回null</returns><br /> public static DataTable DTSelect(string SelectString)<br /> {<br /> errorString = "";<br /> try<br /> {<br /> if (connection.State == ConnectionState.Closed)<br /> {<br /> connection.Open();<br /> }<br /> adapter.SelectCommand.CommandType = CommandType.Text;<br /> adapter.SelectCommand.CommandText = SelectString;<br /> DataTable myDT = new DataTable();<br /> adapter.Fill(myDT);<br /> return myDT;<br /> }<br /> catch (Exception ex)<br /> {<br /> errorString = "数据查询失败：" + ex.Message;<br /> return null;<br /> }<br /> }</p> <p> /// <summary><br /> /// 根据Sql语句更新数据库<br /> /// </summary><br /> /// <param name="UpdataString">更新语句</param><br /> /// <returns>更新成功则返回true</returns><br /> public static bool dbUpdate(string UpdataString)<br /> {<br /> errorString = "";<br /> try<br /> {<br /> if (connection.State == ConnectionState.Closed)<br /> {<br /> connection.Open();<br /> }<br /> command.CommandType = CommandType.Text;<br /> command.CommandText = UpdataString;<br /> int intCount = command.ExecuteNonQuery();<br /> return intCount > 0;<br /> }<br /> catch (Exception ex)<br /> {<br /> errorString = "更新数据库失败：" + ex.Message;<br /> return false;<br /> }<br /> }</p> <p> /// <summary><br /> /// 执行多条SQL语句，实现数据库事务。<br /> /// </summary><br /> /// <param name="SQLStringList">多条SQL语句</param><br /> public static bool ExecuteSqlTran(ArrayList SQLStringList)<br /> {</p> <p> SqlTransaction tx = connection.BeginTransaction();<br /> command.Transaction = tx;<br /> try<br /> {<br /> for (int n = 0; n < SQLStringList.Count; n++)<br /> {<br /> string strsql = SQLStringList[n].ToString();<br /> if (strsql.Trim().Length > 1)<br /> {<br /> command.CommandText = strsql;<br /> command.ExecuteNonQuery();<br /> }<br /> }<br /> tx.Commit();<br /> return true;<br /> }<br /> catch (Exception Etranca)<br /> {<br /> tx.Rollback();<br /> errorString = "数据库操作失败：" + Etranca.Message;<br /> return false;<br /> }</p> <p> }</p> <p> }<br /> }<br />