C# 操作SQL Server數(shù)據(jù)庫(kù), ExecuteReader()方法執(zhí)行T-SQL語(yǔ)句, 游標(biāo)讀取數(shù)據(jù)

--ExecuteNonQuery()
對(duì)連接執(zhí)行 Transact-SQL 語(yǔ)句并返回受影響的行數(shù)，如果SQL語(yǔ)句是對(duì)數(shù)據(jù)庫(kù)的記錄進(jìn)行操作（如記錄的增加、刪除和更新），那么方法將返回操作所影響的記錄條數(shù)。

--ExecuteScalar()
執(zhí)行查詢(xún)，并返回查詢(xún)所返回的結(jié)果集中第一行的第一列。 忽略其他列或行。該方法所返回的結(jié)果為object類(lèi)型，在使用之前必須強(qiáng)制轉(zhuǎn)換為所需的類(lèi)型。

--ExecuteReader()

將 CommandText 發(fā)送到 Connection，并生成 SqlDataReader。DataReader對(duì)象提供了游標(biāo)形式的讀取方式，當(dāng)從結(jié)果行中讀取了一行，則游標(biāo)會(huì)繼續(xù)讀取到下一行。通過(guò)read方法可以判斷數(shù)據(jù)是否還有下一行，如果存在數(shù)據(jù)，則繼續(xù)運(yùn)行返回true，如果沒(méi)有數(shù)據(jù)，則返回false。

創(chuàng)建SQL Server數(shù)據(jù)庫(kù)、數(shù)據(jù)表：

USE master;
GO

--創(chuàng)建數(shù)據(jù)庫(kù)
IF NOT EXISTS(SELECT * FROM dbo.sysdatabases WHERE [name]='TestDB')
	CREATE DATABASE TestDB;
GO

--使用數(shù)據(jù)庫(kù)
USE TestDB;
GO

--創(chuàng)建用戶(hù)表
IF EXISTS(SELECT * FROM sysobjects WHERE [name]='Users')
	DROP TABLE [Users]
GO
CREATE TABLE [Users](
		[Id] [int] IDENTITY(1,1),--主鍵
		[Name] [nvarchar](50) NOT NULL,--姓名
		[Sex] [nvarchar](10),--性別
		PRIMARY KEY([Name])
);
GO

INSERT INTO [Users]([Name],[Sex]) VALUES ('Alice','Female');
INSERT INTO [Users]([Name],[Sex]) VALUES ('Amy','Female');
INSERT INTO [Users]([Name],[Sex]) VALUES ('Bruce','Male');

C#代碼：

using System;
using System.Data;
using System.Data.SqlClient;

namespace SqlServerDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectionString = "Data Source=127.0.0.1,1433;Initial Catalog=TestDB;uid=sa;pwd=123456";
            string sqlstring = "SELECT * FROM [Users];";

            SqlConnection conn = new SqlConnection(connectionString);
            SqlCommand cmd = new SqlCommand();
            try
            {
                conn.Open();
                cmd.Connection = conn;
                cmd.CommandText = sqlstring;
                cmd.CommandType = System.Data.CommandType.Text;

                SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                while (reader.Read())
                {
                    if (reader.HasRows)
                    {
                        Console.WriteLine(reader.GetInt32(0) + " - " + reader.GetString(1) + " - " + reader.GetString(2));
                    }
                }
            }
            catch
            {
                if (conn.State != ConnectionState.Closed)
                {
                    conn.Close();
                }
                throw;
            }

            Console.Read();
        }
    }
}