C#操作SQL Server数据库

　　创建了数据库后，我们得为其创建表，表是数据库中的基本对象。我们通过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); 　}

C#操作SQL Server数据库

标签：