摘要:本文主要向大家介绍了C#编程之C#操作DataReader类,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。
本文主要向大家介绍了C#编程之C#操作DataReader类,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。
一、常用属性
名称
说明
Depth
获取一个值,用于指示当前行的嵌套深度
FieldCount
获取当前行中的列数
HasRows
获取一个值,该值指示 SqlDataReader 是否有行
IsClosed
指定的SqlDataReader 实例是否已关闭
Item[Int32]
获取指定列(数字索引),通常在While.Read()中使用
Item[String]
获取指定列(字符串索引), 通常在While.Read()中使用
RecordsAffected
获取执行 T-SQL 语句所更改、插入或删除的行数
VisibleFieldCount
获取 SqlDataReader 中未隐藏的字段的数目
using MySql.Data.MySqlClient;
using System;
using System.Data.Common;
namespace ConsoleApp
{
class Program
{
static void Main(string[] args)
{
string str = string.Format("Server={0};Port={1};Database={2};Uid={3};Pwd={4};",
"localhost",3306, "wisdompurchase","root","1234");
DbConnection conn = new MySqlConnection(str); //创建连接
DbCommand cmd = conn.CreateCommand(); //创建SqlCommand对象
cmd.CommandText = "SELECT * FROM `t_s_base_user` LIMIT 3";
conn.Open(); //打开连接
using (DbDataReader reader = cmd.ExecuteReader())
{
Console.WriteLine(reader.FieldCount); //2 获取列数
Console.WriteLine(reader.Depth); //0 嵌套深度
Console.WriteLine(reader.HasRows); //true 是否包含行
Console.WriteLine(reader.IsClosed); //false SqlDataReader是否关闭
Console.WriteLine(reader.RecordsAffected); //-1 执行T-SQL语句所插入、修改、删除的行数
Console.WriteLine(reader.VisibleFieldCount); //2 未隐藏的字段数目(一共就两列)
while (reader.Read())
{
Console.WriteLine(reader["realname"]);
//Console.WriteLine(reader[1]); 通过数字索引或字符串索引访问
}
}
conn.Close(); //关闭连接
Console.ReadKey();
}
}
}
View Code
二、常用方法
名称
说明
Read()
前进到下一记录,异步版本ReadAsync
GetString()
返回指定类型的值,其他的都类似
NextResult()
当处理批处理的T-SQL语句时,跳到下一结果,异步版本NextResultAsync
GetValue()
获得该列的值,返回object类型
GetValues()
使用当前列指来填充参数中的对象数组
Close()
关闭 SqlDataReader 对象
using MySql.Data.MySqlClient;
using System;
using System.Data.Common;
using System.Threading;
using System.Threading.Tasks;
namespace ConsoleApp
{
class Program
{
static void Main(string[] args)
{
string str = string.Format("Server={0};Port={1};Database={2};Uid={3};Pwd={4};",
"localhost", 3306, "wisdompurchase", "root", "1234");
DbConnection conn = new MySqlConnection(str); //创建连接
DbCommand cmd = conn.CreateCommand(); //创建SqlCommand对象
cmd.CommandText = "SELECT username,realname FROM `t_s_base_user` LIMIT 3";
conn.Open(); //打开连接
//Console.WriteLine("======同步读取开始=====");
//NormalRead(cmd);
//Console.WriteLine("======同步读取接收=====");
cmd.CommandText = "SELECT username,realname FROM `t_s_base_user`";
CancellationTokenSource tokenSource = new CancellationTokenSource();
CancellationToken cancellToken = tokenSource.Token;
Console.WriteLine("======异步读取开始=====");
AsyncRead(cmd, cancellToken);
Console.WriteLine("======异步读取结束=====");
Console.WriteLine("按下任意键即可取消任务!");
Console.ReadKey();
tokenSource.Cancel();
Console.WriteLine("按下任意键即可关闭连接!");
Console.ReadKey();
conn.Close(); //关闭连接
}
///
///
static void NormalRead(DbCommand cmd)
{
using (DbDataReader reader = cmd.ExecuteReader())
{
while (reader.Read())
{
Console.WriteLine("reader.IsDBNull={0}", reader.IsDBNull(1)); //是否是null值
Console.WriteLine("reader.GetString={0}", reader.GetString(1)); //Get什么类型就返回什么类型,这没啥好说的。
}
Console.WriteLine("reader.GetName={0}", reader.GetName(1)); //realname 由数字获得列名
Console.WriteLine("reader.GetOrdinal={0}", reader.GetOrdinal("realname")); //1 由列名获取其在reader中的数字索引
if (reader.NextResult())
{
Console.WriteLine(reader.GetString(1));
}
}
}
async static void AsyncRead(DbCommand cmd, CancellationToken cancellToken)
{
using (DbDataReader reader = cmd.ExecuteReader())
{
try
{
while (await reader.ReadAsync(cancellToken))
{
Console.WriteLine("reader.IsDBNull={0}", reader.IsDBNull(1)); //是否是null值
Console.WriteLine("reader.GetString={0}", reader.GetString(1)); //Get什么类型就返回什么类型,这没啥好说的。
await Task.Delay(500);
}
}
catch (TaskCanceledException canceleEx)
{
Console.WriteLine("编辑被取消:{0}", canceleEx.Message);
}
catch (Exception ex)
{
Console.WriteLine("遍历报错:{0}", ex.Message);
}
bool NextResult = await reader.NextResultAsync();
if (NextResult)
{
Console.WriteLine(reader.GetString(1));
}
}
}
}
}
本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注职坐标编程语言C#.NET频道!
您输入的评论内容中包含违禁敏感词
我知道了
请输入正确的手机号码
请输入正确的验证码
您今天的短信下发次数太多了,明天再试试吧!
我们会在第一时间安排职业规划师联系您!
您也可以联系我们的职业规划师咨询:
版权所有 职坐标-一站式IT培训就业服务领导者 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
沪公网安备 31011502005948号