第18课-数据库开发及ado.net 连接数据库.增.删.改向表中插入数据并且返回自动编号.SQLDataReade读取数据

18-数据库开发及ado.net

连接数据库...改向表中插入数据并且返回自动编号.SQLDataReade读取数据

ADO.NET

为什么要学习?

我们要搭建一个平台(Web/Winform)让用户方便的操作数据库中的数据。

什么是ADO.NET

是一组库类,System.Data.

Ado.net组成

Connection:用来连接数据库

Command:用来执行SQL语句

DataReader:只读、只进的结果集,一条一条读取数据(SteamReader、XmlReader)

DataAdapter:一个封装了上面3个对象的对象。

数据集(DataSet),临时数据库。

断开式数据操作

Ado.net 中其它常见类

ConnectionStringBuilder  --自动生成连接字符串

Parameter  --带参数的SQL语句

Transaction  --在ADO.NET中使用事务

与DataSet相关的类

DataView ---视图类,DataTable 中的数据以不同的视角查看

DataRowView --- DataView的行

DataTable ---DataSet中的数据表

DataRow --- DataTable中的行

DataColumn --- DataTable中的列

DataRealation --- DataTable与DataTable的关系

Contraint ---DataTable中建立的约束

#region 通过ado.net连接数据库

//1.编写连接字符串

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

//string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Persist Security Info=True;User ID=sa";

//使用windows身份验证方式

//string constr="Data Source=127.0.0.1\BLEACHMSSQL;Initial Catalog=itcast2013;Integrated Security=true";

//2.创建连接对象

SqlConnection con = new SqlConnection(constr);

//3.打开连接

con.Open ();

Console.WriteLine ("使用连接对象");

//4.关闭连接

con.Close ();

//5.释放资源

con.Dispose ();

Console .WriteLine ("连接关闭,并释放资源");

Console .WriteLine ("OK");

Console .ReadKey ();

#endregion

//另外一种连接方式

string constr1 = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;Integrated Security=true";

using (SqlConnection con1 = new SqlConnection(constr1))

{

//con1.Open();

}

Console.ReadKey();

//第一个对象Connection

//1.数据库不可以重复打开

string constr2 = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

using (SqlConnection  con2=new SqlConnection (constr2))

{

con2.Open();

Console.WriteLine("第一次打开数据库连接");

/////数据库不可以重复打开

// con2.Open();

// Console.WriteLine("第二次打开数据库连接");

//判断数据库是否已打开

if (con2.State == System.Data.ConnectionState.Closed)//ConnectionState枚举

{

con2.Open();//如果当前数据库已经关闭,则再次打开。

}

con.Close();//关闭连接,相当于设置障碍

con.Dispose();//相当于把路拆了,这块地可以盖楼了。

Console.ReadKey();

}

/// <summary>

/// 添加操作

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button1_Click(object sender, EventArgs e)

{

//向TblPerson表中插入一条记录

//1.连接数据库

//连接字符串

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

//创建连接对象

using (SqlConnection con=new SqlConnection (constr) )

{

//打开数据库连接

//如果con对象是其它地方传递过来的一个对象,则在打开前最好判断con.State

con.Open();

//向表中插入一条数据

//先构建一个sql语句

string sql = string.Format("insert into TblPerson(uname,uage,uheight) values(‘{0}‘,‘{1}‘,‘{2}‘)", "黄林", 18, 175);

//执行sql语句需要一个“命令对象”

//创建一个命令对象

using (SqlCommand cmd=new SqlCommand (sql,con))

{

#region SqlCommand对象常用的三个方法

//执行sql语句

//当执行 insert,delete,update语句时,一般使用该方法

//cmd.ExecuteNonQuery()

//当执行返回单个值的SQL语句时使用该方法

//cmd.ExecuteScalar()

//当执行sql语句返回多行多列时候,一般使用该方法。查询。

//cmd.ExecuteReader ()

#endregion

//这里要执行insert语句所以用ExecuteNonQuery()方法

//通过调用该方法就会将insert语句交给数据库引擎来执行

//这个方法的返回值是一个Int类型,表示当前Sql语句执行后所影响的行数

int r = cmd.ExecuteNonQuery();

con.Close();

Console.WriteLine("成功插入{0}行", r);

}

}

}

/// <summary>

/// //删除操作

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button2_Click(object sender, EventArgs e)

{

//删除操作

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = string.Format("delete from TblPerson where autoId={0}",19);

using (SqlConnection con = new SqlConnection(constr))

{

using (SqlCommand cmd=new SqlCommand (sql,con))

{

//尽可能晚的开启

con.Open();

int r= cmd.ExecuteNonQuery();

//使用完毕尽可能早的关闭连接

con.Close();

Console.WriteLine("成功删除{0}行", r);

}

}

MessageBox.Show("Ok");

}

/// <summary>

/// 更新操作

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button3_Click(object sender, EventArgs e)

{

//更新操作

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = string.Format("update  TblPerson set uname=‘{0}‘  where autoId={1}", "许正龙",40);

using (SqlConnection con = new SqlConnection(constr))

{

using (SqlCommand cmd = new SqlCommand(sql, con))

{

//尽可能晚的开启

con.Open();

int r = cmd.ExecuteNonQuery();

//使用完毕尽可能早的关闭连接

con.Close();

Console.WriteLine("成功更新{0}行", r);

}

}

MessageBox.Show("Ok");

}

异常处理

可以使用try…catch…finally 来捕获异常

/// <summary>

/// 查询及异常处理方法

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button4_Click(object sender, EventArgs e)

{

//显示表中的记录的条数

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL1;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = "select count(*) from TblClass";

int r = 0;

try

{

using (SqlConnection con = new SqlConnection(constr))

{

using (SqlCommand cmd = new SqlCommand(sql, con))

{

try

{

con.Open();

r = Convert.ToInt32(cmd.ExecuteScalar());

con.Close();

//Console.WriteLine("成功更新{0}行", r);

}

catch (Exception ex1)

{

Console.WriteLine("发生了异常:" + ex1.Message);

}

finally

{

con.Close();

con.Dispose();

}

}

}

}

catch (Exception ex)

{

Console.WriteLine("发生了异常:"+ex.Message );

}

MessageBox.Show("表中有"+ r +"条记录");

}

ConnectionStringBuilder类演示

private void button1_Click(object sender, EventArgs e)

{

SqlConnectionStringBuilder connStrbuilder = new SqlConnectionStringBuilder();

connStrbuilder.DataSource = "127.0.0.1\\BLEACHMSSQL";

connStrbuilder.InitialCatalog = "itcast2013";

connStrbuilder.IntegratedSecurity = true;

connStrbuilder.Pooling = true;

MessageBox.Show(connStrbuilder.ConnectionString);

}

private void Form1_Load(object sender, EventArgs e)

{

SqlConnectionStringBuilder connStrbuilder = new SqlConnectionStringBuilder();

propertyGrid1.SelectedObject = connStrbuilder;

}

/// <summary>

/// 向表中插入数据,返回自动编号

/// </summary>

/// <param name="sender"></param>

/// <param name="e"></param>

private void button5_Click(object sender, EventArgs e)

{

//连接字符串

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = string .Format ("insert into TblClass output inserted.tClassId values(‘{0}‘,‘{1}‘)",textBox1 .Text .Trim (),textBox2 .Text .Trim());

//其中,inserted 是一个触发器

int tclassId = -1;

using (SqlConnection  con=new SqlConnection (constr))

{

using (SqlCommand cmd=new SqlCommand (sql,con))

{

cmd.StatementCompleted += new StatementCompletedEventHandler(cmd_Statementcompleted);

con.Open();

tclassId =Convert.ToInt32 ( cmd.ExecuteScalar());

con.Close();

}

}

MessageBox.Show("成功插入,主键ID为:"+ tclassId +"");

}

private void cmd_Statementcompleted(object sender, StatementCompletedEventArgs e)

{

//输出每条Sql语句执行所影响的行数。

throw new NotImplementedException();

}

查询表中的所有记录

#region 将TblPerson表中的数据输出到控制台

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = "select * from TblPerson";

using (SqlConnection con=new SqlConnection (constr))

{

using (SqlCommand cmd=new SqlCommand (sql,con))

{

con.Open();

using (SqlDataReader reader = cmd.ExecuteReader())

{

//判断当前的reader是否读取到了数据

if (reader .HasRows)

{

///通过列名来获取列的值,将索引写在循环外面,提高效率[建议使用该方式]

int autoIdIndex=reader .GetOrdinal ("autoId");

int unameIndex = reader.GetOrdinal("uname");

int uageIndex = reader.GetOrdinal("uage");

int uheightIndex = reader.GetOrdinal("uheight");

//循环读取每一条数据

while (reader .Read ())

{

#region 通过SqlDataReader的索引器和GetValue()方法获取列值

//通过reader获取行中列的方法一。

//通过reader的所引起可以使用列索引,也可以使用列名。reader["列名"];(性能比较高)

//强烈建议使用列索引,如果必须要使用列名,也要使用列索引。

//读取当前行中的每一列的数据

object obj1 = reader[0];

object obj2 = reader[1];

object obj3 = reader[2];

object obj4 = reader[3];

Console.WriteLine("{0}\t{1}\t{2}\t{3}\t", obj1, obj2, obj3, obj4);

//通过reader获取行中列的方法二。

//reader.GetValue()不支持列名,只支持列索引

object obj5 = reader.GetValue(0);

object obj6 = reader.GetValue(1);

object obj7 = reader.GetValue(2);

object obj8 = reader.GetValue(3);

//this.GetOrdinal(name);根据列名获取列的索引。

#endregion

#region 通过reader获取列值的时候,使用强类型

//autoId, uname, uage, uheight

//当使用强类型的时候,如果数据库中的值为null,则报错。

//避免方式:判断是否为null即可。

int autoId = reader.GetInt32(0);

string name = reader.GetString(1);

//int?表示可空值类型,

int? uage = reader.IsDBNull(2) ?null :(int?) reader.GetInt32(2);

int? height = reader.IsDBNull(3) ? null : (int?)reader.GetInt32(3);

Console.WriteLine("{0}\t{1}\t{2}\t{3}\t", autoId, name, uage, height);

#endregion

#region 通过列名来获取列的值[建议使用该方式]

Console.WriteLine("{0}\t{1}\t{2}\t{3}\t",

reader.GetInt32(autoIdIndex),

reader.GetString(unameIndex),

reader.GetInt32(uageIndex),

reader.GetInt32(uheightIndex));

#endregion

}

}

}

}

}

Console.WriteLine("OK");

Console.ReadKey();

#endregion

}

把表中的数据绑定到控件上

#region 将TblPerson表中的数据输出到控制台

string constr = "Data Source=127.0.0.1\\BLEACHMSSQL;Initial Catalog=itcast2013;user=sa;Password=root";

string sql = "select * from TblPerson";

List <Person> list=new List<Person>();

using (SqlConnection con = new SqlConnection(constr))

{

using (SqlCommand cmd = new SqlCommand(sql, con))

{

con.Open();

using (SqlDataReader reader = cmd.ExecuteReader())

{

//判断当前的reader是否读取到了数据

if (reader.HasRows)

{

///通过列名来获取列的值,将索引写在循环外面,提高效率[建议使用该方式]

int autoIdIndex = reader.GetOrdinal("autoId");

int unameIndex = reader.GetOrdinal("uname");

int uageIndex = reader.GetOrdinal("uage");

int uheightIndex = reader.GetOrdinal("uheight");

//循环读取每一条数据

while (reader.Read())

{

#region 通过列名来获取列的值[建议使用该方式]

//Console.WriteLine("{0}\t{1}\t{2}\t{3}\t",

//    reader.GetInt32(autoIdIndex),

//    reader.GetString(unameIndex),

//    reader.GetInt32(uageIndex),

//    reader.GetInt32(uheightIndex));

Person model = new Person();

model.AutoId = reader.GetInt32(autoIdIndex);

model.UName  = reader.GetString(unameIndex);

model.UAge = reader.IsDBNull(uageIndex) ? null : (int?)reader.GetInt32(uageIndex);

model.UHeight = reader.IsDBNull(uheightIndex) ? null : (int?)reader.GetInt32(uheightIndex);

list.Add (model);

#endregion

}

}

}

}

}

dataGridView1.DataSource = list;

#endregion

/// <summary>

/// 创建Person类,autoId, uname, uage, uheight

/// </summary>

public  class Person

{

public int AutoId

{

get;

set;

}

public string UName

{

get;

set;

}

public int? UAge

{

get;

set;

}

public int? UHeight

{

get;

set;

}

}

时间: 2024-10-26 15:50:06

第18课-数据库开发及ado.net 连接数据库.增.删.改向表中插入数据并且返回自动编号.SQLDataReade读取数据的相关文章

第16课-数据库开发及ado.net-数据库SQl,创建数据库和表,增删改语句,约束,top和Distinct,聚合函数介绍

第16课-数据库开发及ado.net 数据库SQl,创建数据库和表,增删改语句,约束,top和Distinct,聚合函数介绍 SQL语句入门(脚本.命令) SQL全名是结构化查询语言(Structured Query Language) SOL语句是和DBMS“交谈”专用的语言,不同的DBMS都认SQL语法. Sql中字符串使用单引号:通过写俩个单引号来转义一个单引号. Sql中的注释“——” 单行注释比较好 判断俩个数据是否相等使用=(单等号) 在sql语句中sql代码不区分大小写 SQL主要

第17课-数据库开发及ado.net 聚合函数,模糊查询like,通配符.空值处理.order by排序.分组group by-having.类型转换-cast,Convert.union all; Select 列 into 新表;字符串函数;日期函数

第17课-数据库开发及ado.net 聚合函数,模糊查询like,通配符.空值处理.order by排序.分组group by-having.类型转换-cast,Convert.union all;  Select 列 into 新表;字符串函数;日期函数 SQL聚合函数 MAX(最大值).MIN(最小值).AVG(平均值).SUM(和).COUNT(数量:记录的条数) 聚合函数对null不计算.如果一行数据都是null,count(*)包含对空值行.重复行的统计. --聚合函数演示 selec

第20课-数据库开发及ado.net 可空值类型,资料管理器,多条件查询,Case

第20课-数据库开发及ado.net 可空值类型,资料管理器,多条件查询,Case SqlHelper using System; using System.Collections.Generic; using System.Configuration; using System.Data; using System.Data.SqlClient; using System.Text; namespace _02省市联动 { public static  class SqlHelper { //

数据库基础学习4--表格的 增 删 改 查(简单查询与高级查询)

一.增 C:create 增加,创建,向数据库里面添加数据. insert into Fruit values('K009','苹果',3.0,'高青',90,'') insert into Fruit(Ids,Name,Price,Source,Numbers) values('K010','苹果',3.0,'高青',90) 二.改 U:update修改,从数据库表里面修改数据. update Fruit set Source='烟台' where Ids='K001' 三.删 D:delet

ADO.NET 增 删 改 查

ADO.NET:(数据访问技术)就是将C#和MSSQL连接起来的一个纽带 可以通过ADO.NET将内存中的临时数据写入到数据库中 也可以将数据库中的数据提取到内存中供程序调用 ADO.NET所有数据访问技术的基础 连接数据库基本格式:需要两个类1.数据库连接类 SqlConnection2.数据库操作类 SqlCommand 1.连接数据库写连接字符串,立马就要想到有4点要写完,1.连接哪台服务器,2.连接哪个数据库,3.连接用户名,4.密码string sql = "server=.(服务器i

mysql5.7基础 向指定数据库的指定表中插入符合要求的数据

镇场文:       学儒家经世致用,行佛家普度众生,修道家全生保真,悟易理象数通变.以科技光耀善法,成就一良心博客.______________________________________________________________________________________________________ Operating System:UbuntuKylin 16.04 LTS 64bitmysql: Ver 14.14 Distrib 5.7.17, for Linux (

Python---MySQL数据库之四大操作(增 删 改 查)

一.对数据库,表,记录---四大操作(增 删 改 查) 1.操作数据库 (1)对数据库(文件夹):进行增加操作 Create  database  库名; 例:  Create  database  db7 ; 查询库: show  databases; 结果: +-----------------------------+ | Database                   | +----------------------------+ | information_schema | |

数据库开发及ADO.NET

数据库管理系统(DBMS)特点 MySQL 速度快,适合对数据要求并不是十分严谨的地方,去掉了很多中小型企业中不常用的功能 MSSQLServer 与.net结合很好,只能运行在windows平台下,大数据量.大交易量表现不够好,功能比MySQL多 DB2(大型).Oracle(大型).Access(文件). SQLite(极其轻量级数据库) .Sybase等 对于开发人员来讲,大同小异 除Access.SQLServerCE.SQLite等文件型数据库外,大部分数据库需数据库服务器才能运行.学

php基础:数据库的含义和基本操作 增 删 改 查

//数据库是帮我们管理数据的一个软件,我们将数据给他,放进数据库里.他能很稳妥的帮我们管理起来,且效率很高.//php的大部分工作就是  php->连接数据库->写入数据->查出数据->格式化数据->显示出来,//数据库管理数据是以表的形式组成的,多行多列,表头声明好了,一个表创建好了,剩下的就是往里面添加数据 多张表放在一个文件夹里面就形成了库  mysql服务器帮我们管理多个库C:\wamp\bin\mysql\mysql5.6.12\data   数据库中的数据放在这个