class DataBaseUtil{
static string dataSource = "server = 数据库地址; database=数据库表名;uid=用户;pwd=密码";//数据库连接字符串
public static SqlConnection GetConnection()
{
SqlConnection conn = new SqlConnection(dataSource);
try
{
conn.Open();
}
catch (Exception e)
{throw;}
return conn;
}
public static DataTable Query(string sql)
{
DataTable dt = new DataTable();
SqlConnection sqlConnection = GetConnection();
try
{
SqlDataAdapter sqlDataAdapter = new SqlDataAdapter(sql, sqlConnection);
sqlDataAdapter.Fill(dt);
}
catch (Exception e)
{
throw;
}
finally
{
sqlConnection.Close();
}
return dt;
}
public static int UpDate(string sql)
{
int i = 0;
SqlConnection sqlConnection = GetConnection();
SqlTransaction sqlTransaction = sqlConnection.BeginTransaction();
try
{
i = new SqlCommand
{
Connection = sqlConnection,
CommandType = CommandType.Text,
CommandText = sql,
Transaction = sqlTransaction
}.ExecuteNonQuery();
sqlTransaction.Commit();
}
catch
{
sqlTransaction.Rollback();
}
finally
{
sqlConnection.Close();
}
return i;
}
}