C#数据库连接操作
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.SqlClient;
using System.Data;
namespace MySQLClass
{
class MySQL
{
private string MySqlCon = "Server=(local);uid=ake;pwd=zzy123;database=Server";
public DataTable ExecuteQuery(string sqlStr) //用于查询;其实是相当于提供一个可以传参的函数,到时候写一个sql语句,存在string里,传给这个函数,就会自动执行。
{
DataTable dt = new DataTable();
try {
SqlConnection con = new SqlConnection(@MySqlCon);
con.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandType = CommandType.Text;
cmd.CommandText = sqlStr;
SqlDataAdapter msda;
msda = new SqlDataAdapter(cmd);
msda.Fill(dt);
con.Close();
} catch (Exception) {
//throw;
}
return dt;
}
public int ExecuteUpdate(string sqlStr) //用于增删改;
{
int iud = 0;
try {
SqlConnection con = new SqlConnection(@MySqlCon);
con.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = con;
cmd.CommandType = CommandType.Text;
cmd.CommandText = sqlStr;
iud = cmd.ExecuteNonQuery();
con.Close();
} catch (Exception) {
}
return iud;
}
}
}
© 著作权归作者所有
文章评论(0)