C#操作SQL Server数据库

在c#程序开发中经常需要和SQL Server数据库打交道，下面我们就了解一下c#操作SQL Server数据库的方法：

 

1.概述

   首先是为我们的程序添加必要的引用以及一些数据成员。因为我们的程序涉及到数据库的访问操作，所以必须要运用到数据提供者（Data Provider）的对象。在.Net框架下，我们主要运用的数据提供者分为两类，一类是Sql类型的，另一类是OleDb类型的。它们涉及到的命名空间分别为System.Data.SqlClient和System.Data.OleDb。因为我们的程序访问的是SQL Server数据库，所以我们运用的数据提供者对象应为Sql类型的。原因很简单，该类型的对象是专门为SQL Server数据库而设计的，所以性能得到了大大的优化。所以，在我们的程序的开始处添加如下一句语句：using System.Data.SqlClient;

1.定义变量

   添加对System.Data.SqlClient命名空间的引用后，我们接下来为程序添加一些必要的数据成员，这些数据成员可以完成一些对数据库及其对象的操作。

  private string ConnectionString = "Data Source=192.168.0.10;Initial Catalog=test;Persist Security Info=True;User ID=sa;Password=test";   // 连接字符串，包含了连接参数
　private SqlConnection conn = null; //  数据库连接对象。实现和数据库的连接
　private SqlCommand cmd = null;  //  数据库连接命令对象。指定执行的SQL语句
　private string sql = null;   // 存放SQL语句的。

 

2.连接数据库

   // 创建一个连接
　conn = new SqlConnection(ConnectionString);

 

 

  ...... //其他处理代码

 

 

 if( conn.State == ConnectionState.Open)

      conn.Close() ;

 

3.创建数据库

  

   在创建了数据库连接对象后，我们就可以在程序中运用它了。首先，我们在程序中动态地创建一个SQL Server类型的数据库。我们将数据库创建在C:mysql目录下，所以读者要练习该实例的话得先在C:下创建一个名为mysql的文件夹，否则会出错！创建数据库的关键是函数中的sql对象，通过该对象我们指定了数据库文件的一些基本属性。之后，我们新创建了一个SqlCommand对象，通过该对象我们就实际完成了对数据库的操作。函数的实现如下；

   private void button1_Click(object sender, System.EventArgs e)
　{
　// 打开数据库连接
　if( conn.State != ConnectionState.Open)
　　conn.Open();
　string sql = "CREATE DATABASE mydb ON PRIMARY"
　　+"(name=test_data, filename ='C:\mysql\mydb_data.mdf', size=3,"
　　+"maxsize=5, filegrowth=10%)log on"
　　+"(name=mydbb_log,filename='C:\mysql\mydb_log.ldf',size=3,"
　　+"maxsize=20,filegrowth=1)";
　cmd = new SqlCommand(sql, conn);
　try
　{
　　cmd.ExecuteNonQuery();
　}
　catch(SqlException ae)
　{
　　MessageBox.Show(ae.Message.ToString());
　}
　}

4．创建表并添加记录：

　　创建了数据库后，我们得为其创建表，表是数据库中的基本对象。我们通过CREATE TABLE这句SQL语句完成创建表的操作，表被创建后，我们就确定了其模式（Schema）。之后，我们还通过INSERT语句向该表中添加了四条记录以为后用。函数的实现如下：

private void button2_Click(object sender, System.EventArgs e)
　{
　// 打开数据库连接
　if( conn.State == ConnectionState.Open)
　　conn.Close();
　ConnectionString ="Integrated Security=SSPI;" +"Initial Catalog=mydb;" +
　　"Data Source=localhost;";　　　
　conn.ConnectionString = ConnectionString;
　conn.Open();
　sql = "CREATE TABLE myTable"+"(myId INTEGER CONSTRAINT PKeyMyId PRIMARY KEY,"+
　　"myName CHAR(50), myAddress CHAR(255), myBalanceFLOAT)";
　cmd = new SqlCommand(sql, conn);
　try
　{
　　cmd.ExecuteNonQuery();
　　　　　// 向表中添加记录
　　sql = "INSERT INTO myTable(myId, myName,myAddress, myBalance) "+
"VALUES (1001, 'Puneet Nehra', 'A 449 Sect 19, DELHI', 23.98 ) " ;
　　cmd = new SqlCommand(sql, conn);
　　cmd.ExecuteNonQuery();
sql = "INSERT INTO myTable(myId, myName,myAddress, myBalance) "+
"VALUES (1002, 'Anoop Singh', 'Lodi Road, DELHI', 353.64) " ;
　　cmd = new SqlCommand(sql, conn);
　　cmd.ExecuteNonQuery();　
sql = "INSERT INTO myTable(myId, myName, myAddress, myBalance) "+
"VALUES (1003, 'Rakesh M', 'Nag Chowk, Jabalpur M.P.', 43.43) " ;
　cmd = new SqlCommand(sql, conn);
　cmd.ExecuteNonQuery();　
sql = "INSERT INTO myTable(myId, myName, myAddress, myBalance) "+
"VALUES (1004, 'Madan Kesh', '4th Street, Lane 3, DELHI', 23.00) " ;
　　cmd = new SqlCommand(sql, conn);
　　cmd.ExecuteNonQuery();
　}
　catch(SqlException ae)
　{
　　MessageBox.Show(ae.Message.ToString());
　}
　}

5．创建通用SQL语句执行函数：

　　考虑到程序后面大量运用SqlCommand对象对数据库进行操作，我们在程序中设计了一个通用的SQL语句执行函数。它根据数据库连接对象以及sql对象创建一个SqlCommand对象，然后完成对数据库的相关操作。函数的实现如下：

private void ExecuteSQLStmt(string sql)
　{
　// 打开数据库连接
　if( conn.State == ConnectionState.Open)
　　conn.Close();
　ConnectionString ="Integrated Security=SSPI;" +
　　"Initial Catalog=mydb;" +
　　"Data Source=localhost;";　　　
　conn.ConnectionString = ConnectionString;
　conn.Open();
　cmd = new SqlCommand(sql, conn);
　try
　{
　　cmd.ExecuteNonQuery();
　}
　catch(SqlException ae)
　{
　　MessageBox.Show(ae.Message.ToString());
　}
　}

6．创建存储过程：

　　我们通过CREATE PROCEDURE这句SQL语句创建存储过程，同时函数中还调用了上面的通用SQL语句执行函数。函数的实现如下：

private void button3_Click(object sender, System.EventArgs e)
　{
　sql = "CREATE PROCEDURE myProc AS"+
　　" SELECT myName, myAddress FROM myTable GO";
　ExecuteSQLStmt(sql);
　}

　　存储过程创建完毕后，我们可以在SQL Server企业管理器中找到其属性。

7．创建视图：

　　创建视图的过程与上面创建存储过程的方法类似，只是运用到的SQL语句为CREATE VIEW。函数的实现如下：

private void button4_Click(object sender, System.EventArgs e)
　{
　sql = "CREATE VIEW myView AS SELECT myName FROM myTable";
　ExecuteSQLStmt(sql);
　}

　　同样，在创建完成后，我们可以在企业管理器中找到其属性。

8．查看表中的数据：

　　查看表中的数据过程中，我们运用到了ADO.Net中的SqlDataAdapter以及DataSet这两个重要的对象。其中SqlDataAdapter对象是前面提到的Sql类型的数据提供者对象，它是专门用于SQL Server数据库的。而DataSet对象则是与数据提供者对象的类型无关的，它适用于任何类型的数据提供者对象，它被包含在System.Data命名空间之中，可谓是ADO.Net体系结构的核心。其数据的访问模式为非连接模式（Disconnected），即数据从数据库（或是Xml数据流）中被读到DataSet对象后，DataSet对象就断开了原来的连接。在完成一系列操作后，DataSet对象再连接到数据库并完成数据的更新操作。SqlDataAdapter对象提供了Fill和Update两个基本的方法以完成数据的读取和更新操作。

　　所以下面是函数的实现方法：

private void button5_Click(object sender, System.EventArgs e)
　{
　// 打开数据库连接
　if( conn.State == ConnectionState.Open)
　　conn.Close();
　ConnectionString ="Integrated Security=SSPI;" +
　　"Initial Catalog=mydb;" +
　　"Data Source=localhost;";　　　
　conn.ConnectionString = ConnectionString;
　conn.Open();
　// 创建数据适配器
SqlDataAdapter da = new SqlDataAdapter("SELECT * FROM myTable", conn);
// 创建一个数据集对象并填充数据，然后将数据显示在DataGrid控件中
DataSet ds = new DataSet("myTable");
da.Fill(ds, "myTable");
dataGrid1.DataSource = ds.Tables["myTable"].DefaultView;
　}

该操作的结果就是在程序的DataGrid控件中显示表中的数据。

9．查看存储过程中的数据：

　　该过程和上面查看表中的数据的过程类似，其中调用的存储过程就是我们前面创建的那个。函数的实现如下：

private void button6_Click(object sender, System.EventArgs e)
　{
　// 打开数据库连接
　if( conn.State == ConnectionState.Open)
　　conn.Close();
　ConnectionString ="Integrated Security=SSPI;" +
　　"Initial Catalog=mydb;" +
　　"Data Source=localhost;";　　　
　conn.ConnectionString = ConnectionString;
　conn.Open();　　　
　// 创建数据适配器
　SqlDataAdapter da = new SqlDataAdapter("myProc", conn);
　// 创建一个数据集对象并填充数据，然后将数据显示在DataGrid控件中
　DataSet ds = new DataSet("SP");
　da.Fill(ds, "SP");
　dataGrid1.DataSource = ds.DefaultViewManager;
　}
10．查看视图中的数据：

　　该过程和上面的两个过程也是类似的，调用的视图是我们前面创建的那个视图。函数的实现如下：

private void button7_Click(object sender, System.EventArgs e)
　{
　// 打开数据库连接
　if( conn.State == ConnectionState.Open)
　　conn.Close();
　ConnectionString ="Integrated Security=SSPI;" +
　　"Initial Catalog=mydb;" +
　　"Data Source=localhost;";　　　
　conn.ConnectionString = ConnectionString;
　conn.Open();　　　
　// 创建数据适配器
SqlDataAdapter da = new SqlDataAdapter("SELECT * FROM myView", conn);
// 创建一个数据集对象并填充数据，然后将数据显示在DataGrid控件中
DataSet ds = new DataSet();
da.Fill(ds);
dataGrid1.DataSource = ds.DefaultViewManager;
　}

11．创建其他数据库对象：

　　在关系型数据库中，常涉及到的数据库对象还包括了索引、约束等。它们是高效实现数据库查询操作和满足数据库完整性规则的必要条件。我们可以通过Create Index语句来创建索引，通过CREATE RULE语句来创建约束（也即规则）。函数的实现如下：

private void button8_Click(object sender, System.EventArgs e)
　{
　sql = "CREATE UNIQUE INDEX "+
　　"myIdx ON myTable(myName)";　　
　ExecuteSQLStmt(sql);　
　sql = "CREATE RULE myRule "+
　　"AS @myBalance >= 32 AND @myBalance < 60";
　ExecuteSQLStmt(sql);
　}

12．修改表：

　　上面我们为数据库创建了一个表，但是实际的应用过程中可能还要为该表添加一些字段或是删除某些字段，这就要通过ALTER TABLE这句SQL语句来完成了。其中添加字段的方法是ALTER TABLE…ADD…，而删除字段的方法则是ALTER TABLE…DROP…，本程序中我们为表添加了一个字段。函数的实现如下：

private void button9_Click(object sender, System.EventArgs e)
　{
　sql = "ALTER TABLE MyTable ADD "+
　　"newCol TIMESTAMP";　　　　　　　　　　　
　ExecuteSQLStmt(sql);
　}

13．删除表：

　　删除表的操作就是将某个不再有用的表从数据库中删除，通过DROP TABLE语句我们可以完成此操作。函数的实现如下：

private void button10_Click(object sender, System.EventArgs e)
　{
　string sql = "DROP TABLE myTable";
　ExecuteSQLStmt(sql);
　}