C#学习之路（1）--数据库技术

用户2032165

发布于 2018-06-05 16:45:51

1.9K0

发布于 2018-06-05 16:45:51

前言

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

ADO.NET概述

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

ADO.NET组件

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

DataSet对象

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

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

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

具体代码

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

String url = @"Data Source=KQVRDUTYAH5ADL1\SQLEXPRESS;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对象 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=KQVRDUTYAH5ADL1\SQLEXPRESS;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();

        }

    }
}