数据库就好比水源,存储了大量的数据。Connection好比伸进水的水龙头,与水进行了连接。Command像抽水机,为抽水提供动力和执行方法,然后把水返给上面的水管。DataAdapter通过发动机,把水送到水库里面。DataReader把水送到用户。DataSet对象是一个大水库,即使断开连接,水仍然存在。DataTable对象是水库中的独立的水池子。
1、首先建立与数据库的连接
<span style="font-size:18px;"></span><pre name="code" class="csharp">MySqlConnection mycon=new MySqlConnection("Data Source=localhost;Initial Catalog=mysql;User Id=root;PassWord=root"); /*创建一个Connection对象mycon。"Data Source=localhost;Initial Catalog=mt;User Id=root;PassWord=root"是连接数据库的信息。Data Source为主机名,Initial Catalog数据库名,User Id用户名,PassWord 密码*/ mycon.Open();//打开数据库 if(mycon.state==connectionstate.open){ } //判断是否打开数据库
2、对数据库的命令操作(有两种方法)
MySqlCommand My_com = My_con.CreateCommand(); My_com.CommandText = SQLstr;//执行DSQL语句? /*在mycon连接下新建一个Command对象。*/ MySqlCommand My_com = new MySqlCommand(SQLstr, My_con);
Command对象有两种执行SQL语句的方法ExecuteNonQuery(),执行SQL语句,并返回受影响的行数,发送增、删、改命令时。ExecuteReader(),执行SQL语句,并生成一个包含数据的MySqlDataReader实例,发送查询命令。
3、DataReader对象
<span style="font-size:18px;">MySqlDataReader My_read = My_com.ExecuteReader(); /*Command对象的ExecuteReader()方法可以生成DataReader对象。如果想读取其中的数据可以通过Read()方法。Read()方法使DataReader对象前进到下一条记录*/ while(My_read .Read()) { if (My_read[1].ToString() != "" && My_read[1].ToString()!=null) cobox.Items.Add(My_read[1].ToString()); } </span>
4、DataAdapter对象
<span style="font-size:18px;">MySqlDataAdapter da = new MySqlDataAdapter("select * from logontable ", mycon);//创建另一种方法是 </span>
<span style="font-size:18px;">MySqlCommand My_com = new MySqlCommand(SQLstr, My_con); MySqlDataAdapter da=new MySqlDataAdapter(); da. SelectCommand= My_com; DataSet MyDataSet = new DataSet();//创建一个DataSet da.Fill(MyDataSet);//dataadapter中的数据填充DataSet 把水从水源送到水库中进行保存 DataTable tbl = MyDataSet.Tables[0];//获取数据库中表的内容 </span>
using System; using System.Collections.Generic; using System.Linq; using System.Text; using MySql.Data.MySqlClient; using MySql.Data; using System.Data; namespace lianxi { class Program { static void Main(string[] args) { MySqlConnection mycon = new MySqlConnection("Data Source=localhost;Initial Catalog=mt;User Id= rootm;PassWord=rootm"); mycon.Open(); MySqlCommand mycmd = new MySqlCommand("insert into mytable(ID,name) values('2','zhao')",mycon); if (mycmd.ExecuteNonQuery() > 0) { Console.WriteLine("数据卡插入成功"); } MySqlDataAdapter da = new MySqlDataAdapter("select * from mytable ", mycon);//创建一个 MySqlDataAdapter对象 DataSet MyDataSet = new DataSet();//创建一个DataSet da.Fill(MyDataSet);//dataadapter中的数据填充DataSet 把水从水源送到水库中进行保存 DataTable tbl = MyDataSet.Tables[0];//获取第一张表 foreach (DataColumn col in tbl.Columns) { Console.WriteLine(col.ColumnName);//打印列名 } DataRow irow = tbl.Rows[0];//获取第一行的信息 Console.WriteLine(irow["Name"]);//打印第一行每一列的信息 Console.WriteLine(irow["Pass"]); MySqlCommand msc = new MySqlCommand("select * from mytable", mycon); MySqlDataReader mdr = msc.ExecuteReader();//执行SQL语句,并生成一个包含数据的MySqlDataReader对象的实例 MySqlDataReader从水库到用户的水管 while (mdr.Read())//打印出每个用户的用户名和密码 { Console.WriteLine(mdr["Name"].ToString()); Console.WriteLine(mdr["Pass"].ToString()); } } } }
时间: 2024-10-18 09:59:51