C#与数据库访谈本事总括(十五卡塔 尔(英语:State of Qatar)

VS.NET(C#)数据库接口之C#访问DataSet对象演示(代码案例),vs.net

在上节的基础上,把创建在DataSet对象中两个表的数据输出到页面上来。实现如下效果:

ylg娱乐官网 1

ylg娱乐官网 2

点击“访问DataSet对象”,显示DataSet中的所有数据表数据

给按钮单击事件添加ShowDataSet(DataSet ds)函数调用

 protected void Button1_Click(object sender, EventArgs e)
    {
        ShowDataSet(ds_Forum);
    }

private void ShowDataSet(DataSet ds)  
   {  
       // 构建输出字符串  
       StringBuilder htmlStr = new System.Text.StringBuilder();  

       // 遍历Forum中的所有表(使用foreach遍历)  
       foreach (DataTable dt in ds.Tables)  
       {  
           // 表开始  
           htmlStr.Append("<table border='1' cellPadding='5' cellSpacing='0' style='font-size:9pt;font:宋体'>");  

           #region 表的头部  
           // 表头开始  
           htmlStr.Append("<tr style='background-color=#f0f0f0'>");  

           // 遍历表中所有列(使用for遍历)  
           for (int i = 0; i < dt.Columns.Count; i++)  
           {  
               htmlStr.Append(string.Format("<td><strong>{0}</strong></td>", dt.Columns[i].ColumnName));  //表头  
           }  

           htmlStr.Append("</tr>"); // 表头一行结束  
           #endregion  

           #region 表的数据行  
           // 遍历表中所有行  
           for (int i = 0; i < dt.Rows.Count; i++)  
           {  
               // 数据行开始  
               htmlStr.Append("<tr>");  
               // 遍历行中列  
               for (int j = 0; j < dt.Columns.Count; j++)  
               {  
                   if (!dt.Rows[i].IsNull(j))  
                   {  
                       htmlStr.Append(string.Format("<td>{0}</td>", dt.Rows[i][j]));  
                   }  
                   else  
                   {  
                       htmlStr.Append(string.Format("<td>{0}</td>", string.Empty));  
                   }  

               }  
               // 数据行结束  
               htmlStr.Append("</tr>");  
           }  
           #endregion  

           //表结束  
           htmlStr.Append("</table><br>");  
       }  
       //输出DataSet页面数据  
       Response.Write(htmlStr);  
   }  

在上节的基础上,把创建在DataSet对象中两个表的数据输出到页面上来。实现…

具体代码

  • 数据库连接

    调用Connection对象的open()方法进行指定的数据源连接。
    Close()方法肯定就是关闭指定的数据源连接咯。
    Dispose()方法肯定就是释放Connection对象所占的资源了。
    一般使用try {}catch {}finally{}块进行相关数据库相关的操作。

String url = @"Data Source=KQVRDUTYAH5ADL1SQLEXPRESS;Initial Catalog=user;Integrated Security=True";
            conn = new SqlConnection(url);
            conn.Open();
  • 创建Command对象

    Command对象用于执行数据库的命令操作。
    ExecuteNonQuery():一般用于删除,修改,更新等操作。返回一个int型数据,就是受查询影响的行数。一般大于0就是操作成功,反之,操作失败。
    ExecuteReader():一般用于查询操作,返回一个数据集Reader对象。通过遍历Reader,就能获取查询的数据。这跟MySQL的ResultSet很像。

   String sql = "insert into Student values('" + name + "','" + course + "')";
  sqlCommand.CommandText = sql;
  int result = sqlCommand.ExecuteNonQuery();
  • 创建DataAdapter对象

    SelectCommand,InsertCommand,UpdateCommand,DeleteCommand这是DataAdapter对象的4个属性。用于定义处理数据存储中数据的命令,并且每一个命令都是对Command对象的一个引用,可以共享同一个数据源。

    Fill()方法:该方法用于执行SelectCommand里面的SQL命令,把数据源的数据填充到DataSet对象。
    Update()方法:该方法用于将DataSet对象中某一个数据表更改的内容更新到对应的真实的数据库里面的数据表中。

 adapter = new SqlDataAdapter(s, conn);
  • 创建SqlCommandBuilder对象

    创建这个对象,需要传入SqlDataAdapter的对象。为什么要创建这个对象?因为这个对象可以自动生成与DataSet对象关联的操作,如更新,删除,增加等。如果没有这个对象,SqlDataAdapter对象调用Update()方法会报一个异常:System.InvalidOperationException:
    当传递具有已修改行的 DataRow 集合时,更新要求有效的 UpdateCommand

   scb = new SqlCommandBuilder(adapter);
  • 创建DataSet对象

    ylg娱乐官网,DataSet对象用于实现通过DataAdapter里面的数据来提供程序控件与数据库相连接。DataSet的结构与关系数据库的结构很相似,它包括表集合(TABLES)和描述表之间关系的表集合。

    AcceptChanges()方法:该方法一般用于修改了DataSet对象里面某一个表里面的内容,然后把修改的具体内容提交给DataSet对象中的表,调用了这个方法,RowState记录就初始化了,注意:如果用调用到RowState初始化的DataTable再去调用Update()方法去更新数据库里面的表,将不会有任何变化。

  //DataSet对象用于实现DataAdapter数据提供程序控件与数据库相连接
  //DataSet的结构与关系数据库的机构相似,它包括表集合和描述表之间的关系集合
            data = new DataSet("myDataSet");

            DataTable myTable = new DataTable("StudentTable");

            data.Tables.Add(myTable);

            //把数据源中的数据填充到DataSet对象
            adapter.Fill(data, "StudentTable");

            dataGridView1.DataSource = myTable;
  • 完整实例代码

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
namespace WindowsFormsApplication19
{
    public partial class dasd : Form
    {
        //BindingManagerBase类是一个抽象类,管理所有
        //绑定相同的数据源和数据成员的控件
        private BindingManagerBase myBind;
        private String TAG = "Form";

        private SqlConnection conn;
        private SqlDataAdapter adapter;
        private DataSet data ;
        //这样会让SqlDataAdapter对象自动实现与DataSet更改和关联的SQL语句
        private SqlCommandBuilder scb;
        private int i;
        private int selectedId=-1;
        private int selectedSid=-1;
        private SqlCommand sqlCommand;
        public dasd()
        {
            InitializeComponent();
            //设置DataGirdView选中模式 为每一行选中
            this.dataGridView1.SelectionMode = DataGridViewSelectionMode.FullRowSelect;
            initData();
        }

        private void initData()
        {
            String url = @"Data Source=KQVRDUTYAH5ADL1SQLEXPRESS;Initial Catalog=user;Integrated Security=True";
            conn = new SqlConnection(url);
            conn.Open();
            String s = "select * from Student";


            adapter = new SqlDataAdapter(s, conn);

            scb = new SqlCommandBuilder(adapter);

            //DataSet对象用于实现DataAdapter数据提供程序控件与数据库相连接
            //DataSet的结构与关系数据库的机构相似,它包括表集合和描述表之间的关系集合
            data = new DataSet("myDataSet");

            DataTable myTable = new DataTable("StudentTable");

            data.Tables.Add(myTable);

            //把数据源中的数据填充到DataSet对象
            adapter.Fill(data, "StudentTable");

            dataGridView1.DataSource = myTable;

            sqlCommand = new SqlCommand(s,conn);
        }

        private void add_Click_1(object sender, EventArgs e)
        {

            String name="独一无二的小马同志"+i;
            String course="计算机";
            String sql = "insert into Student values('" + name + "','" + course + "')";
            sqlCommand.CommandText = sql;

            int result = sqlCommand.ExecuteNonQuery();

            if (result>0)
            {
                MessageBox.Show("添加记录成功!");
            }

            doUpdateDataSet();
            i++;


        }

        private void button1_Click(object sender, EventArgs e)
        {

            MyLog.i(TAG, "selectedId=" + selectedId);
            if (selectedId ==-1)
            {
                MessageBox.Show("没有选中任何一项");
                return;
            }

           //先从DataSet获取我们之前定义的StudentTable表
            DataTable myTable = data.Tables["StudentTable"];

            myTable.Rows[selectedId].Delete();

            //对指定的数据集DataSet中的数据表StudentTable更新到数据源。
           int result= adapter.Update(data,"StudentTable");
           MyLog.i(TAG,"result="+result);
           if (result>0)
           {
               MessageBox.Show("删除记录成功");
           }

           //把修改结果提交到数据集dataset中的数据表studenttable
           data.AcceptChanges();
           selectedId = -1;
           selectedSid = -1;
           dataGridView1.Rows[int.Parse(dataGridView1.RowCount.ToString())-1].Selected = false;
        }

        private void Form1_Load(object sender, EventArgs e)
        {
            //默认不选中
            if (dataGridView1.RowCount > 0)
            {
                dataGridView1.Rows[0].Selected = false;
            }

            dataGridView1.AllowUserToAddRows = false;
            //设置只读模式
            dataGridView1.ReadOnly = true;
        }

        private void dataGridView1_CellClick(object sender, DataGridViewCellEventArgs e)
        {
            //获取当前行的index
            selectedId = dataGridView1.CurrentRow.Index;
            //获取当前行的sid
            selectedSid = int.Parse(dataGridView1.Rows[selectedId].Cells[0].Value.ToString());
            MyLog.i(TAG, "您选中的selectedId=" + selectedId + ",sid=" + selectedSid);
        }

        private void del1_Click(object sender, EventArgs e)
        {

            if (selectedId == -1)
            {
                MessageBox.Show("您没有选中任何一项");
                return;
            }
            MyLog.i(TAG, "selectedId=" + selectedId+",sid="+selectedSid);
            String sql = "delete from Student where sid=" + selectedSid;

            sqlCommand.CommandText = sql;
            int result = sqlCommand.ExecuteNonQuery();
            if (result>0)
            {
                MessageBox.Show("删除成功");
            }
            doUpdateDataSet();
        }

        private void doUpdateDataSet()
        {

            data.Tables.Clear();
            data.AcceptChanges();
            adapter.Fill(data, "StudentTable");
            dataGridView1.DataSource = data.Tables["StudentTable"];
            dataGridView1.Rows[0].Selected = false;
            selectedId = -1;
            selectedSid = -1;
        }

        private void add1_Click(object sender, EventArgs e)
        {
            DataTable myTable=data.Tables["StudentTable"];
            //要添加的sid 肯定是最后一项数据的sid+1
            int sid=int.Parse(dataGridView1.Rows[int.Parse(dataGridView1.RowCount.ToString())-1].Cells[0].Value.ToString())+1;
            Object[] newRow = {sid, "我是沉梦" + i, "英语" };
            myTable.Rows.Add(newRow);
            int result = adapter.Update(data, "StudentTable");
            if (result > 0)
            {
                MessageBox.Show("添加成功");
            }

            //把修改结果提交给DataSet中的表里
            data.AcceptChanges();
            i++;
        }

        private void edit1_Click(object sender, EventArgs e)
        {
            int sid = selectedSid;
            MyLog.i(TAG,"sid=" + sid);
            String sql="update Student set name='"+textBox2.Text+"', course='"+textBox3.Text+"'  where sid='"+sid+"'";

            sqlCommand.CommandText = sql;

            int result = sqlCommand.ExecuteNonQuery();

            if (result > 0)
            {
                MessageBox.Show("修改成功!");
            }
            else
            {
                MessageBox.Show("修改失败!");
            }
            doUpdateDataSet();                                                                                      
        }

        private void edit2_Click(object sender, EventArgs e)
        {
            DataTable myTable=data.Tables["StudentTable"];
            //获取某一行指定列的值
            myTable.Rows[selectedId]["name"]=textBox2.Text;
            myTable.Rows[selectedId]["course"] = textBox3.Text;
            int result=adapter.Update(data, "StudentTable");
            if (result > 0)
            {
                MessageBox.Show("修改成功!");
            }
            else
            {
                MessageBox.Show("修改失败!");
            }

            data.AcceptChanges();

        }

    }
}
  • 演示效果
这里写图片描述

DataGrid代码示例

    通过以下的步骤,能将数据库里的数据动态绑定到DataGrid对象里并显示。

   
(1)在D盘下建立一个Access类型的数据库,命名为Student.mdb。在其中新建一张Studentlnfo的表,其中的字段如表所示。 

字    段

中文描述

数据类型

备    注

SID

学号

文本

主键

SName

姓名

文本

  一 

Sex

性别

文本

  一 

 

 

 

 

 

 

注意:本书表中“一”表示无须设置相关信息。

    完成后往其中插入一些记录,如(001,Tom,Male)。

    (2)打开Visual
Studio环境后,选择“文件”|“新建”|“新建网站”命令,在弹出的新建网站”对话框中选择“ASP.NET项目”,输入网站名testDataGrid和路径CAroot~DataGrid,登录模块所有代码和配置文件均放在此项目下。

   
(3)在集成开发环境中的“解决方案资源管理器”里,选中项目,右击,在弹出的快捷菜单中选择“添加新项”命令,新建一个Web配置文件,命名为Web.config。该配置文件主要用来管理登录模块的一些全局性数据。

    其中,在配置文件里设置数据库的连接属性,使用OleDB的Data
Provider,连接到Access数据源上,代码如下。

  

<configuration>
  <appSettings>
<add key="connStr" value="Porvider=Microsoft.Jet.OleDB.4.0; Data Source=D:login.mdb "></add>
  </appSettings>
<connectionStrings />

 

 
 (4)在集成开发环境中的“解决方案资源管理器”里,选中项目,右击,在弹出的快捷菜单中选择“添加新项”命令,新建一个Web窗体,命名为showDataGrid.aspx。

   
(5)打开“工具箱”的“Web窗体”,从中拖曳一个DataGrid控件到页面上,从DataGrid的属性栏中,可以看到该DataGrid对象叫DataGrid1。

   
选中DataGridView控件,右击,在弹出的快捷菜单中选择”属性”命令,在属性栏的Columns中单击“…”按钮,在弹出的“编辑列”对话框中,通过“添加”命令,依次向DataGridView控件里添加“学号”、“姓名”和“性别”3列,并把每列的DataPropertyName设置成该列对应的数据库字段,用于数据绑定。具体设置如表所示。

数据列名

DataPropertyName

学号

SID

姓名

SName

性别

Sex

 

 

 

 

 

 

(6)双击窗体的空白处,进入相应的逻辑代码文件showDataGrid.aspx.cs。

  在该文件的顶端,添加数据库访问引用的命名空间语句:    

  using System.Data.SqlClient;

 

  并在class的开头添加连接数据库的字符串定义:     

Private static string strConnect =System.Configuration.ConfigurationManager.AppSettings["connstr"];

 

  由于使用的是DataProvider,所以ADO.NET组件的对象都以OleDb开头。

    上述代码的主要业务逻辑是:

   
(1)根据连接字符串,创建数据库连接对象,并根据连接对象创建OLeDbCommand对象。

    (2)根据SQL语句,查询所有学生的信息,以SID的/顷序排列。

   
(3)使用OleDbDataApapter对象,将查询结果填充到DataSet中的。均Dataset数据表里。

    (4)将DataGrid的数据源设置成。均Dataset数据表,实现数据绑定。

   
这样,当打开此页面时,DataGrid就能与Access数据库绑定,显示数据库里的学生信息。

adapter.SelectCommand= mySqlDataSetCmd;

ADO.NET组件

ADO.NET有2个重要的组成部分:DataSet对象和.NET数据提供者。
DataSet对象用于以表格形式在程序中放置一组数据,它不关心数据的来源。
数据提供者包含很多针对数据源的组件,设计者通过这些组件可以使程序与指定的数据源进行链接。.NET数据提供者主要包括:Connection对象,Command对象,DataReader对象以及DataAdapter对象。


ADO.NET 代码综合示例

    前面已经介绍过OLE DB.NET和SQL
Server.NET数据提供者可以用来连接不同的数据源。

  以下代码不仅综合演示了使用ADO.NET的这两种数据提供者访问数据库的一般步骤,而且说明了使用不同种类的ADO.NET组件集合访问数据库的一般步骤。

  可以通过代码进一步了解这两种数据提供者访问方式的异同之处。

4 结束语

前言

在7月10日就要去扬州实习了,首先是为期2个月的培训。一个月的Java,一个月的C#。在这一个月里面,准备梳理一下java和C#的基础知识,同时也进行更深一步的学习。最近也一直在听八三夭的一首,我不想改变世界,我只想不被世界改变。同时也对自己的未来充满着信心和憧憬。


数据库访问综述

   
前面讲述了用两种不同的数据提供者(Provider)访问连接数据库的方式,如果数据源是SQL
Server,则使用SQL
Server的Provider;如果数据源是ODBC或是其他类型的数据库,则可以选用OLE
DB的Provider。

    前面还讲述了使用Connection+Command+DataReader对象和使用Connection+
DataAdapter+DataSet对象的数据库访问方式。

    根据DataReader的特性,以Connection+Command+DataReader方式访问数据库的使用场景有:

  • 访问数据只用于显示,而不修改。
  • 仅对一个数据源进行操作,或是对单表进行操作。
  • 对于数据只希望向后顺序访问,而不进行重复遍历。
  • 访问数据量小,不需要在内存中大量存储数据。
  • 需要访问的结果集太大,不能一次性地全部放入内存,此时也能使用DataReader来逐次访问。

    而DataSet支持离线的访问方式,可以有以下的应用:

  • 同一业务逻辑需要访问多个数据源,比如同时要向SQL
    Server和Oracle数据库中请求数据。
  • 由于DataSet可以包含多个DataTable,如果需要访问的数据对象来自多个表,可用DataSet的Table来分别存储管理。
  • 如果访问操作的数据量比较大,利用DataSet的离线访问机制可以减轻对数据库负载的压力。

//根据IP地址和端口号获取相应的远程对象

ADO.NET概述

ADO.NET是美国微软公司推出的.NET平台中的一种数据访问技术。ADO.NET类库中提供了用于数据连接,处理数据操作的类。


DataGrid控件与数据绑定

    DataGrid控件的主要目的是实现“数据绑定”(Data
Binding),即把DataGrid控件上显示的数据同后台数据库的数据绑定在一起,同步地一起变化。

另外,DataGrid控件以表格的形式显示了查询到的数据结果集,默认的访问方式是只读而不能修改,通过设置,可以实现记录的修改和删除功能。

//发布该服务器端激活对象

DataSet对象

ADO.NET一个比较突出的特点是支持离线访问,即在非连接环境下对数据进行处理。DataSet是支持离线访问的关键对象,它将数据存储在缓存中。


DataGrid控件与数据库访问技术

   
在实际的应用项目中,通常需要把用ADO.NET组件获得的数据信息显示在界面上,供用户浏览或修改。

  可以通过使用.NET的DataGrid控件实现这种功能。

随着传统的数据库、计算机网络和数字通信技术的飞速发展,以数据分布存储和分布处理为主要特征的分布式数据库系统的研究和开发越来越受到人们的关注。但由于其开发较为复杂,在一定程度上制约了它的发展。基于此,本文提出了在.Net环境下使用一种新的开发语言C#结合ADO.Net数据访问模型来开发分布式数据库系统,大大简化了开发过程。

创建一个ADO.NET数据库应用程序一般步骤

  • 创建Windows窗体。
  • 创建Connection对象,连接数据库。创建Command对象,执行SQL命令。
  • 创建DataAdapter对象,提供数据源与记录集之间的数据交换,数据库与内存中的数据交换。
  • 创建DataSet对象,将从数据源中得到的数据保存在内存中,然后对数据进行相关的各种操作。

使用SQL Server .NET  Provider

  

  以下的代码演示了如何使用SQLServer的.NETProvider来连接和访问数据。
//连接字符串
string connectionString="server=local;database=Northwind;user=sa;pwd=;";
//建立连接
Sqlconnection =new SqlConnection(connectionString);
//SQL语句
string strSql= "select UserID, UserName from User";
//根据连接对象和SQL语句创建SqlCommand对象
SqlCommand cmd=new SqlCommand(strSql, conn);
conn.Open();
//使用Command对象创建SqlDataReader对象
SqlDataReader  reader=cmd.ExecuteReader();
//使用DataReader对象填充DataGrid 控件
DataGrid_User.DataSource=reader;
DataGrid_User.DataBind();
//关闭连接
conn.Close();
   上述代码也演示了使用Connection、Command和DataReader对象访问数据库的一般方式。

 

(SqlConn);

尾言

这样一个基本的数据库程序就完成了,实现了基本的增删改查等功能。如果你们有时间,可以进行更一步的优化,实现代码的复用呢。

使用OLE DB.NET  Provider

OLE DB的数据提供者可以访问Access和SQL等数据库,代码如下:
//设置连接字符串
 string dbname=@" user.mdb";
 string db=Server.MapPath(dbPath);
 string connectionString ="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=" +db;
 //设置SQL语句
 string strSQL=" select  UserId, UserName from User";
//根据连接字符串,创建连接对象
OleDbConnection conn=new OleDbConnection(connectionString);
//根据连接对象和SQL语句,创建DataAdapter对象
OleDbDataAdapter  da=new OleDbDataAdapter(strSQL, conn);
//创建OleDbCommandBuilder, 用来对DataAdapter更好地操作
OleDbCommandBuilder  cb=new OleDbCommandBuilder(da);

 

   上述代码演示了从根据连接字符串建立连接对象,到创建DataAdpate对象填充DataSet,再到使用DataSet对象提交数据更新以及与DataGrid绑定的一般过程。

     
上述代码也演示了使用Connection、DataAdapter和DataSet访问数据库的一般流程。

  ADO.NET采用离线的方式访问数据库,所以使用DataSet从数据库获得数据后的操作数据的过程中,不必保持与数据库的连接,直到向数据库提交更新数据时,才需连上数据库。这种做法适合于海量数据更新的情况。

   
 而在上述代码里,因为数据操作过程比较简单,所以直到数据更新提交结束才断开连接,也就是说,并没有采用“离线”的数据库连接访问方式。

  不采用“离线”方式的理由是:在数据库访问操作中,频繁连接和断开数据源也需要耗费一定的系统资源,如果这个代价要比保持短时间的数据连接所需的代价大,那么宁可选择“一直在线”的连接方式。

(CmdString,Conn);//CmdString为要执行的命令

//将数据源中的数据导入到数据集对象

{MessageBox.Show( “指定的url地址不可到达 ” + nullExp.Message );}

{MessageBox.Show( “指定获得的对象定义不对” + remExp.Message );}

远程对象的获取:

· 均衡负载。负载在各处理机间分担,可避免临界瓶颈。

1 分布式数据库系统

try

3.1.1系统结构图

3.2.1 远程对象的发布与获取

//建立数据库的连接

·
可靠性高。数据分布在不同场地,且存有多个副本,即使个别场地发生故障,不致引起整个系统的瘫痪。

发表评论

电子邮件地址不会被公开。 必填项已用*标注