现在的位置: 首页 > 综合 > 正文

visualc#中动态操作sqlserver数据库

2012年12月16日 ⁄ 综合 ⁄ 共 4745字 ⁄ 字号 评论关闭
在编写数据库应用程序的时候,我们可以通过sql语句来动态创建、修改数据库以及其中的对象。本文我就向大家介绍如何运用visual c#来动态操作sql server数据库,其中包括如何创建一个sql server数据库以及如何创建其中的表、存储过程、视图、索引之类的数据库对象。本文还介绍了如何动态地修改表的模式,如何从表、存储过程以及视图中读取数据并显示在应用程序的数据库控件中。

我们知道sql语句在操作数据库时运用得最多的是select、insert、update和delete等对于数据的操作,而本文重点向大家介绍的是对于数据库及其对象的操作。通过掌握这些基本的操作方法,读者就可以更加灵活地进行数据库应用程序的开发。

开发实例及步骤

1.界面设计:

本文向大家介绍一个运用visual c#动态操作数据库的实例,实例的界面如图1所示。

图1

从上图可知,我们的实例程序只包含了10个按钮控件以及一个datagrid控件。按钮控件分为三类:

第一类为创建数据库以及数据库对象的按钮;

第二类为查看不同数据库对象中的数据的按钮;

第三类则为修改数据库对象的按钮。其中的datagrid控件则是用于显示数据的。

2.添加引用及数据成员:

设计完界面,我们就可以开始编写程序代码。首先是为我们的程序添加必要的引用以及一些数据成员。因为我们的程序涉及到数据库的访问操作,所以必须要运用到数据提供者(data provider)的对象。在.net框架下,我们主要运用的数据提供者分为两类,一类是sql类型的,另一类是oledb类型的。它们涉及到的命名空间分别为system.data.sqlclient和system.data.oledb。因为我们的程序访问的是sql server数据库,所以我们运用的数据提供者对象应为sql类型的。原因很简单,该类型的对象是专门为sql server数据库而设计的,所以性能得到了大大的优化。所以,在我们的程序的开始处添加如下一句语句:


using system.data.sqlclient;

添加对system.data.sqlclient命名空间的引用后,我们接下来为程序添加一些必要的数据成员,这些数据成员为我们的类的私有成员,通过它们我们可以完成一些对数据库及其对象的操作。


private string connectionstring = "integrated
            security=sspi;initial catalog=;data source=localhost;";
            private sqlconnection conn = null;
            private sqlcommand cmd = null;
            private string sql = null;

至于各个数据成员的意义,我想大家一看就应该会明白了,所以这里就不多说了。

3.处理数据库连接对象:

对于数据库应用程序而言,连接到相应的数据库是一个必不可少的步骤,我们的程序也不例外。所以在我们的程序的构造函数中得先创建一个数据库连接对象,方法如下:


public form1()
            {
            //
            // windows 窗体设计器支持所必需的
            //
            initializecomponent();
            // 创建一个连接
            conn = new sqlconnection(connectionstring);
            }

这样,我们在以后的对于数据库的操作中就可以运用该数据库连接对象了。

而同时,在我们的程序结束时,我们有必要关闭该数据库连接对象,否则可能会引发一些意想不到的错误。所以得在程序的已重载的dispose函数中添加关闭数据库连接对象的语句,不过由于.net框架具有自动垃圾回收(garbage collection)功能,所以我们不必像在c++语言中那样显式的将该对象销毁。具体方法如下:


protected override void dispose( bool disposing )
            {
            // 程序运行完毕,确保数据库连接已经关闭
            if (conn.state == connectionstate.open)
            conn.close();
            if( disposing )
            {
            if (components != null)
            {
            components.dispose();
            }
            }
            base.dispose( disposing );
            }

4.创建sql server数据库:

在创建了数据库连接对象后,我们就可以在程序中运用它了。首先,我们在程序中动态地创建一个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());
            }
            }

5.创建表并添加记录:

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

完成此操作后,我们可以在本机的sql sever企业管理器中打开mydb数据库并找到该表。图2显示了该表的设计图示:

图2

6.创建通用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());
            }
            }

7.创建存储过程:

我们通过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企业管理器中找到其属性,如图3所示。

图3

8.创建视图:

创建视图的过程与上面创建存储过程的方法类似,只是运用到的sql语句为create view。函数的实现如下:


private void button4_click(object sender, system.eventargs e)
            {
            sql = "create view myview as select myname from mytable";
            executesqlstmt(sql);
            }

同样,在创建完成后,我们可以在企业管理器中找到其属性,如图4所示。

抱歉!评论已关闭.