c#中await方法实现异步连接sql server数据库

发布时间:2021-01-22编辑:脚本学堂
本文介绍了c#异步连接sql server数据库的方法,在c#中使用await方法实现数据库异步连接,并介绍了c#连接sqlserver并执行sql的方法与实例代码。

一、c#异步连接sql server数据库的方法

.net最新版提供了await方法,可以轻松实现到数据库的异步连接:
 

复制代码 代码示例:
readonly string ConnectionString = "Data Source=database_server_name;Initial Catalog=Store;Integrated Security=True";
protected async void ExecuteCommandAsync()
{
using (SqlConnection con = new SqlConnection(ConnectionString))
{
 await con.OpenAsync();
}
}

附,c#连接sqlserver并执行sql的方法。

代码:
 

复制代码 代码示例:

public class CommonFileUtil
{
string coonString="server=.;database=MySchool(你的数据库名称);uid=sa(登录数据库时的名称);pwd=123(密码可为空)";
SqlConnection coon=new SqlConnection(coonString);
 
 private void CreateConnection(object sender, EventArgs e)
 {
  string rs = "";
  SqlConnection conn = CreateConnection();
  //创建SqlCommand的实例
  SqlCommand cmd = conn.CreateCommand();
  //sql语句
  cmd.CommandText = "select id,name from table1";
  //打开连接
  conn.Open();
  //执行sql
  cmd.ExecuteNonQuery();
  //若要创建 SqlDataReader,必须调用 SqlCommand 对象的 ExecuteReader 方法,而不要直接使用构造函数
  SqlDataReader dr = cmd.ExecuteReader();
  //有点类似于java的arrylist方式
  while (dr.Read())
  {
rs += dr["id"] + " " + dr["name"] + "//n";
  }
  //关闭连接
  conn.Close();
 }
 
 private void CallSP()
 {
  string rs = "";
  SqlConnection conn = CreateConnection();
  SqlCommand cmd = conn.CreateCommand();
  //sp的名称
  cmd.CommandText = "searchDate";
  //sp的参数
  cmd.Parameters.Add("@id", "234");
  cmd.Parameters.Add("@name", "bcd");
  //指定如何解释命令字符串,这里是存储过程
  cmd.CommandType = CommandType.StoredProcedure;
  conn.Open();
  cmd.ExecuteNonQuery();
  SqlDataReader dr = cmd.ExecuteReader();
  while (dr.Read())
  {
rs += dr["id"] + " " + dr["name"] + "//n";
  }
  conn.Close();
 }
 
 private SqlConnection CreateConnection()
 {
  //连接本地数据库的连接字符窜
  string str = "server=(local);database=testdb;user id=sa;pwd=00000000";
  //如果是远程连接,则例:server=192.168.0.1;
  //创建连接
  SqlConnection conn = new SqlConnection(str);
  return conn;
 }
}

public class CommonFileUtil
{
private void CreateConnection(object sender, EventArgs e)
{
string rs = "";
SqlConnection conn = CreateConnection();
//创建SqlCommand的实例
SqlCommand cmd = conn.CreateCommand();
//sql语句
cmd.CommandText = "select id,name from table1";
//打开连接
conn.Open();
//执行sql
cmd.ExecuteNonQuery();
//若要创建 SqlDataReader,必须调用 SqlCommand 对象的 ExecuteReader 方法,而不要直接使用构造函数
SqlDataReader dr = cmd.ExecuteReader();
//有点类似于java的arrylist方式
while (dr.Read())
{
 rs += dr["id"] + " " + dr["name"] + "//n";
}
//关闭连接
conn.Close();
}

private void CallSP()
{
string rs = "";
SqlConnection conn = CreateConnection();
SqlCommand cmd = conn.CreateCommand();
//sp的名称
cmd.CommandText = "searchDate";
//sp的参数
cmd.Parameters.Add("@id", "234");
cmd.Parameters.Add("@name", "bcd");
//指定如何解释命令字符串,这里是存储过程
cmd.CommandType = CommandType.StoredProcedure;
conn.Open();
cmd.ExecuteNonQuery();
SqlDataReader dr = cmd.ExecuteReader();
while (dr.Read())
{
 rs += dr["id"] + " " + dr["name"] + "//n";
}
conn.Close();
}

private SqlConnection CreateConnection()
{
//连接本地数据库的连接字符窜
string str = "server=(local);database=testdb;user id=sa;pwd=00000000";
//如果是远程连接,则例:server=192.168.0.1;
//创建连接
SqlConnection conn = new SqlConnection(str);
return conn;
  }
 }

此外还可以采用xml保存连接信息。

建立过程如下:
1、右击工程名->添加->新建项。
2、选择"应用程序配置文件",App.config文件。
3、在其中添加连接信息。

例如:
 

复制代码 代码示例:

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <connectionStrings>
 <add name="DB_Connection" connectionString="Data Source=(local);Initial Catalog=DB_NAME;Integrated Security=SSPI" providerName="System.Data.SqlClient"/>
 <add name="REMOTE_DB_Connection" connectionString="Data Source=192.168.1.1;Initial Catalog=DB_DIS_BASE;" providerName="System.Data.SqlClient"/>
  </connectionStrings>
</configuration>

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <connectionStrings>
 <add name="DB_Connection" connectionString="Data Source=(local);Initial Catalog=DB_NAME;Integrated Security=SSPI" providerName="System.Data.SqlClient"/>
 <add name="REMOTE_DB_Connection" connectionString="Data Source=192.168.1.1;Initial Catalog=DB_DIS_BASE;" providerName="System.Data.SqlClient"/>
  </connectionStrings>
</configuration>

4、注意其中远程连接不要用SSPI。

5、读取配置信息的代码:
 

复制代码 代码示例:

//strDataBaseName为需要连接的数据库连接字,即App.config中的DB_Connection或REMOTE_DB_Connection
private static SqlConnection CreateConnection(string strDataBaseName)
{
SqlConnection con = null;
 
try 
{
 //连接远程数据库的配置信息
 string connectDBStr = System.Configuration.ConfigurationManager.ConnectionStrings[strDataBaseName].ConnectionString.ToString(); 
 
 //创建连接对象
 con = new SqlConnection(connectDBStr);
 
 //返回对象
 return con;
}
catch(Exception ex)
{
 //抛出异常
 throw new Exception(string.Format("创建数据库连接处理中发生异常,获取{0}的配置信息出错", strDataBaseName));
}
}

//strDataBaseName为需要连接的数据库连接字,即App.config中的DB_Connection或REMOTE_DB_Connection
private static SqlConnection CreateConnection(string strDataBaseName)
{
SqlConnection con = null;

try
{
 //连接远程数据库的配置信息
 string connectDBStr = System.Configuration.ConfigurationManager.ConnectionStrings[strDataBaseName].ConnectionString.ToString();
 
 //创建连接对象
 con = new SqlConnection(connectDBStr);
 
 //返回对象
 return con;
}
catch(Exception ex)
{
 //抛出异常
 throw new Exception(string.Format("创建数据库连接处理中发生异常,获取{0}的配置信息出错", strDataBaseName));
}
}