Đọc truyện hoc tap

Chào các bạn! Vì nhiều lý do từ nay Truyen2U chính thức đổi tên là Truyen247.Pro. Mong các bạn tiếp tục ủng hộ truy cập tên miền mới này nhé! Mãi yêu... ♥

lab asp

Trước Sau

Màu nền

Font chữ

Font size

Chiều cao dòng

XÂY D*NG THU VI*N

DATA ACCESS

Ð* Ng*c Cu*ng - ITDLU

Email: [email protected]

M*c l*c

1

Xây d*ng t*ng Data

Xây d*ng t*ng Data ........................................................................................................ 2

Xây d*ng thu vi*n Data Access ...................................................................................... 3

Vi*t code cho l*p Post (Post.cs) .................................................................................. 5

Vi*t code cho l*p DataProvider (DataProvider.cs) ...................................................... 6

Vi*t code cho l*p SqlDataProvider (SqlDataProvider.cs) ............................................ 7

B* sung code vào l*p DataProvider ............................................................................ 9

Test ............................................................................................................................... 10

Luy*n t*p ...................................................................................................................... 15

Làm ti*p các th* t*c còn l*i ........................................................................................... 16

Th* t*c và các hàm b* sung Post_Count .................................................................. 17

Th* t*c và các hàm b* sung Post_All ........................................................................ 17

Th* t*c và hàm b* sung Post_Single ........................................................................ 18

Th* t*c và hàm b* sung Post_Find ........................................................................... 19

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider ................................................. 20

S* d*ng l*p CBO d* t* d*ng chuy*n d* li*u t* DataReader sang d*i tu*ng ............. 24

Cách s* d*ng l*p CBO ............................................................................................. 25

Xây d*ng thu vi*n Core * m*c t*ng quát ..................................................................... 27

B* sung code cho l*p DataProvider .......................................................................... 29

B* sung code cho l*p SqlDataProvider ..................................................................... 29

B* sung ti*p code cho l*p DataProvider ................................................................... 31

Xây d*ng thu vi*n DataAccess s* d*ng thu vi*n Core.dll ........................................... 32

[email protected]

Xây d*ng t*ng Data

2

Xây d*ng t*ng Data

T*o co s* d* li*u d*t tên là Sample. Sau dó t*o m*t b*ng nhu hình và thi*t l*p giá tr*

t* tang cho c*t PostID

Quy t*c d*t tên th* t*c (Stored Procedure - SP) nhu sau: X_Y

Trong dó:

X: Tên c*a b*ng

Y: Ch*c nang mà th* t*c th*c hi*n

Ví d*:

Tên th* t*c Mô t*

Post_All L*y t*t c* record

Post_Single L*y m*t record theo PostID

Post_Find L*y nhi*u record theo di*u ki*n nào dó

Post_Add Thêm m*t record vào b*ng Post

Post_Update C*p nh*t m*t record theo PostID

Post_Delete Xóa m*t record theo PostID

[email protected]

3

Xây d*ng thu vi*n Data Access

Post_Count Ð*m t*t c* record ho*c d*m theo di*u ki*n nào dó

Post_Paging L*y các record theo trang (phân trang)

... ...

T*o th* t*c Post_Add nhu sau: chú ý tên và d* li*u c*a các tham s*

CREATE PROCEDURE

[Post_Add]

@PostID int output,

-- output: tuong tu nhu truyen tham chieu trong OOP

@Title nvarchar(50

),

@Body nvarchar(4000)

,

@Publish

datetime

AS

INSERT INTO

[Post]

(

[Title]

,

[Body]

,

[Publish]

)

VALUES

(

@Title

,

@Body

,

@Publish

)

-- Lay gia tri tu tang cua record vua moi them vao

SET @PostID = @@IDENTITY

Xây d*ng thu vi*n Data Access

1. T*o m*t thu m*c * Desktop d*t tên là Sample

2. M* Microsoft Visual Studio (VS), t*o m*t project thu vi*n (Class Library Project)

và d*t tên là DataAccess

[email protected]

4

Xây d*ng thu vi*n Data Access

3. T*o 3 class:

Tên Class Mô t*

DataProvider L*p tr*u tu*ng ch*a các phuong th*c abstract

SqlDataProvider L*p k* th*a t* l*p DataProvider, dùng cho SQL Server

Post L*p ánh x* t* b*ng Post

[email protected]

B*ng ánh x* ki*u d* li*u SQL Server sang ki*u d* li*u trong C#

DBType

*

5

Xây d*ng thu vi*n Data Access

C# Type

...char String

...text String

bit Bool

datetime DateTime

smalldatetime DateTime

smallint Int16

int Int32 (int)

bigint Int64 (long)

float float

decimal Decimal

money Double

real Double

... ...

Vi*t code cho l*p Post (Post.cs)

Tên c*t DBType

C# Property C# Type

PostID int PostID int ho*c Int32

Title Nvarchar(50) Title String

Body Nvarchar(max) Body String

Publish Datetime (du*c phép null) Publish

DateTime?

Phiên b*n .NET 2.0 (VS 2005) code nhu sau

using

System;

namespace

DataAccess

{

public class

Post

{

private int

_PostID;

public int

PostID

{

get { return

_PostID; }

set { _PostID = value

; }

}

private string

_Title;

public string

Title

{

get { return

_Title; }

set { _Title = value

; }

}

private string

_Body;

*

[email protected]

public string

Body

{

get { return

_Body; }

set { _Body = value

; }

}

private DateTime

? _Publish;

public DateTime

? Publish

{

get { return

_Publish; }

set { _Publish = value

; }

}

public

Post()

{

}

6

Xây d*ng thu vi*n Data Access

Các phiên b*n t* .NET 3.5 v* sau (t* VS 2008 v* sau) có th* code rút g*n nhu sau

ho*c theo cách code c*a phiên b*n .NET 2.0

using

System;

namespace

DataAccess

{

public class

Post

{

public int PostID { get; set

; }

public string Title { get; set

; }

public string Body { get; set

; }

public DateTime? Publish { get; set

; }

public

Post()

{

}

}

Vi*t code cho l*p DataProvider (DataProvider.cs)

using

System;

using

System.Data;

namespace

DataAccess

{

public abstract class DataProvider

{

public abstract int PostAdd(Post

post);

}

}

[email protected]

Vi*t code cho l*p SqlDataProvider (SqlDataProvider.cs)

7

Xây d*ng thu vi*n Data Access

Trong l*p SqlDataProvider có s* d*ng l*p ConfigurationManager d* l*y chu*i k*t n*i

t* web config/app config. Mu*n s* d*ng du*c l*p này thì ph*i thêm m*t thu vi*n

System.Configuration vào project hi*n t*i. Cách thêm nhu sau:

B*m chu*t ph*i vào m*c References (bên c*a s* Solution) ch*n Add Reference

Ch*n th* .NET trong c*a s* v*a m*i hi*n ra, sau dó ch*n dòng

System.Configuration và b*m OK

[email protected]

using

System;

using

System.Data.SqlClient;

using

System.Configuration;

using

System.Data;

namespace

DataAccess

{

public class SqlDataProvider :

DataProvider

{

private string

_ConnectionString;

public SqlDataProvider(string

connectionStringName)

{

// Lay chuoi ket noi tu web config / app config

_ConnectionString =

ConfigurationManager

.ConnectionStrings[connectionStringName]

.ConnectionString;

}

// Ham tao mot ket noi den CSDL

protected SqlConnection

GetSqlConnection()

{

try

{

return new SqlConnection

(_ConnectionString);

}

catch

{

throw new Exception("SqlConnection"

);

}

public override int PostAdd(Post

post)

{

// 1. Tao doi tuong SqlConnection

using (SqlConnection

cnn = GetSqlConnection())

{

// 2. Tao doi tuong SqlCommand

SqlCommand

cmd = cnn.CreateCommand();

// 2.1 Dat loai command la SP va ten thu tuc

// Thuc hien truy van tu SP

8

Xây d*ng thu vi*n Data Access

cmd.CommandType = CommandType

.StoredProcedure;

// Truyen ten cua SP

cmd.CommandText = "Post_Add"

;

// 2.2 Truyen ten, kieu du lieu va gia tri tham so

// Tuong ung voi phan PostID output trong SP

// Do cot PostID tu tang nen khong can truyen gia tri

cmd.Parameters.Add("@PostID", SqlDbType

.Int)

.Direction = ParameterDirection

.Output;

cmd.Parameters.Add("@Title", SqlDbType

.NVarChar, 50)

.Value = post.Title;

[email protected]

9

Xây d*ng thu vi*n Data Access

cmd.Parameters.Add("@Body", SqlDbType

.NVarChar, 4000)

.Value = post.Body;

// chi co kieu du lieu nullable

// (them dau ? sau kieu du lieu)

// moi phai kiem tra HasValue

(post.Publish.HasValue)

cmd.Parameters.Add("@Publish", SqlDbType

.DateTime)

.Value = post.Publish.Value;

else

cmd.Parameters.Add("@Publish", SqlDbType

.DateTime)

.Value = DBNull

.Value;

// 3. Mo ket noi

cnn.Open();

// Thuc hien them mot record voi cac gia tri

// duoc truyen thong qua cacs Parameter

// Ket qua cua ham ExecuteNonQuery la

// so record duoc them vao CSDL

// > 0: them vao thanh cong

// = 0: khong co hang nao duoc them ~ that bai

// 4. Goi ham ExecuteNonQuery cua doi tuong SqlCommand

int

rs = cmd.ExecuteNonQuery();

(rs > 0)

// 5. Lay gia tri id tu tang cua record vua them vao

return (int)cmd.Parameters["@PostID"

].Value;

return

0;

}

}

B* sung code vào l*p DataProvider

private static DataProvider _Instance = null

;

public static DataProvider

Instance

{

get

{

if (_Instance == null

)

_Instance = new SqlDataProvider("ConnectionString"

);

return

_Instance;

}

B*m Ctrl + Shift + B ho*c ch*n menu Build > Build Solution d* build project

[email protected]

Test

1. Thêm project ki*u Console (Console Application) trong thu m*c Sample và d*t

tên là Test

[email protected]

10

Test

2. Set Startup Project: b*m chu*t ph*i vào Project Test và ch*n Set as StartUp

Project

3. Thêm file App.Config project Console

[email protected]

11

Test

4. Thêm thu vi*n DataAccess vào project Console

[email protected]

12

Test

5. M* t*p t*p tin App.config và thêm vào do*n mã sau

<?xml version="1.0" encoding="utf-8"

?>

<configuration

>

<connectionStrings

>

<add name="ConnectionString"

connectionString="

server=.\sqlexpress;database=sample;integrated

security=true"

/>

</connectionStrings

>

[email protected]

13

Test

</configuration

>

Name: tuong *ng v*i chu*i ConnectionString

trong thu*c tính Instance c*a

l*p

DataProvider

public static DataProvider

Instance

{

get

{

if (_Instance == null

)

_Instance = new SqlDataProvider("ConnectionString"

);

return

_Instance;

}

ConnectionString: chu*i k*t n*i (có th* khác nhau tùy t*ng máy, d*u

"ch*m"

trong .\sqlexpress tuong duong v*i ch* (local)\sqlexpress)

6. Thêm do*n code sau vào hàm Main trong l*p Program.cs

static void Main(string

[] args)

{

// Tao mot doi tuong de them vao CSDL

Post p = new Post

();

p.Title = "A Title"

;

p.Body = "Lorem Ip sum"

;

// Them du lieu

int rs = DataProvider

.Instance.PostAdd(p);

(rs > 0)

Console.WriteLine("New post id is "

+ rs);

else

Console.WriteLine("Insert failed!"

);

Console

.Read();

}

7. Ch*y và xem k*t qu*

8. Tuong t* thêm m*t record khác v*i thu*c tính Publish d*t b*ng DateTime.Now.

Sau dó dùng SQL Server d* ki*m d* li*u v*a du*c thêm vào.

[email protected]

14

Test

Luy*n t*p

1. Tuong t* nhu trên t*o th* t*c Post_Update và b* sung thêm phuong th*c

PostUpdate vào thu vi*n DataAccess d* g*i th* t*c trên.

2. T*o th* t*c Post_Delete và phuong th*c PostDelete

Hu*ng d*n:

T*o th* t*c Post_Update

CREATE PROCEDURE

[Post_Update]

@PostID int

,

@Title nvarchar(50

),

@Body nvarchar(4000

),

@Publish

datetime

AS

UPDATE [Post]

SET

[Title] = @Title

,

[Body] = @Body

,

[Publish] =

@Publish

WHERE [PostID] = @PostID

B* sung thêm phuong th

*c vào l*p DataProvider

public abstract int PostUpdate(Post

post);

B* sung code vào l*p SqlDataProvider

Ð* ti*t ki*m th*i gian b*n có th* rê chu*t vào ch* DataProvider trong l*p

SqlDataProvider và b*m vào nút mui tên xu*ng > ch*n Implement abstract class nhu

hình sau d* VS t* d*ng sinh 1 ph*n mã

Sau khi b*m vào dó thì VS s* sinh ra do*n mã nhu sau

[email protected]

15

Luy*n t*p

public override int PostUpdate(Post

post)

{

throw new NotImplementedException

();

}

16

Làm ti*p các th* t*c còn l*i

Xóa dòng throw new NotImplementedException().Copy & Paste t* hàm

PostAdd, sau dó s*a l*i nh*ng ph*n c*n thi*t d* phù h*p v*i SP Post_Update. Ph*n

in d*m là ph*n du*c thay d*i

public override int PostUpdate(Post

post)

{

using (SqlConnection

cnn = GetSqlConnection())

{

SqlCommand

cmd = cnn.CreateCommand();

cmd.CommandType = CommandType

.StoredProcedure;

cmd.CommandText = "Post_Update"

;

cmd.Parameters.Add("@PostID", SqlDbType

.Int)

.Value = post.PostID;

cmd.Parameters.Add("@Title", SqlDbType

.NVarChar, 50)

.Value = post.Title;

cmd.Parameters.Add("@Body", SqlDbType

.NVarChar, 4000)

.Value = post.Body;

(post.Publish.HasValue)

cmd.Parameters.Add("@Publish", SqlDbType

.DateTime)

.Value = post.Publish.Value;

else

cmd.Parameters.Add("@Publish", SqlDbType

.DateTime)

.Value = DBNull

.Value;

cnn.Open();

return

cmd.ExecuteNonQuery();

}

Ki*m tra k*t qu*

T*o th* t*c Post_Delete và làm tuong t*. Chú ý: th* t*c này ch* có 1 tham s*

CREATE PROCEDURE

[Post_Delete]

@PostID

int

AS

DELETE

[Post]

WHERE [PostID] = @PostID

Làm ti*p các th* t*c còn l*i

Post_Count Ð*m t*t c* bài post

Post_All L*y t*t c* bài post (s*p x*p theo m*t PostID gi*m d*n)

Post_Single Tìm bài post theo PostID

Post_Find Tìm ki*m các bài post theo Title

[email protected]

Hu*ng d*n:

Th* t*c và các hàm b*

sung Post_Count

SP Post_Count

CREATE PROCEDURE

[Post_Count]

AS

SELECT COUNT(PostID) FROM [Post]

DataProvider.cs

public abstract int

PostCount();

SqlDataProvider.cs

public override int

PostCount()

{

using (SqlConnection

cnn = GetSqlConnection())

{

SqlCommand

cmd = cnn.CreateCommand();

cmd.CommandType = CommandType

.StoredProcedure;

cmd.CommandText = "Post_Count"

;

cnn.Open();

object rs = cmd.ExecuteScalar();

return Convert.ToInt32(rs);

}

}

17

Làm ti*p các th* t*c còn l*i

Khi truy v*n SP Post_Count thì b*ng k*t qu* tr* v* nhu sau, ch* có 1 hàng và 1 c*t. Ð*

l*y du*c ô d* li*u dó 1 cách nhanh chóng ngoài cách dùng DataReader thì b*n dùng

phuong th*c ExcecuteScalar, sau dó ép v* ki*u mà b*n mu*n.

Th* t*c và các hàm b* sung Post_All

SP Post_All

CREATE PROCEDURE

[Post_All]

AS

SET NOCOUNT ON

-- sv tu tim hieu tac dung cua lenh nay

SELECT * FROM [Post] ORDER BY [PostID]

DESC

[email protected]

DataProvider.cs

public abstract List<Post

> PostAll();

SqlDataProvider.cs

18

Làm ti*p các th* t*c còn l*i

public override List<Post

> PostAll()

{

using (SqlConnection

cnn = GetSqlConnection())

{

SqlCommand

cmd = cnn.CreateCommand();

cmd.CommandType = CommandType

.StoredProcedure;

cmd.CommandText = "Post_All"

;

cnn.Open();

// Tao doi tuong SqlDataReader de doc du lieu tuan tu tu csdl

using (SqlDataReader

reader =

cmd.ExecuteReader(CommandBehavior

.CloseConnection))

{

// Tao mot danh sach de chua du lieu doc duoc

List<Post> list = new List<Post

>();

// Do kq tra ve la mot ds nhieu record nen phai dung

// vong lap while de doc tung reader

// reader.Read() => doc mot record tu csdl

while

(reader.Read())

{

// Trich du lieu tu 1 record va day vao doi tuong Post

Post p = new Post

();

// reader[ten cot] => doc gia tri cua mot o^ du lieu

// Kieu du lieu tra ve la object => ep ve kieu du lieu tuong ung voi

// tung property cua doi tuong

p.PostID = Convert.ToInt32(reader["PostID"

]);

p.Title = reader["Title"

].ToString();

p.Body = reader["Body"

].ToString();

// Do cot Publish duoc phep null nen kiem tra truoc khi ep kieu du lieu

// DBNull.Value: gia tri NULL trong database

if (reader["Publish"] != DBNull

.Value)

p.Publish = DateTime.Parse(reader["Publish"

].ToString());

list.Add(p);

}

return

list;

}

Th* t*c và hàm b* sung Post_Single

SP Post_Single

CREATE PROCEDURE [dbo].

[Post_Single]

@PostID

int

AS

[email protected]

SET NOCOUNT

ON

SELECT * FROM [Post] WHERE [PostID]=

@PostID

DataProvider.cs

public abstract Post PostSingle(int

postId);

SqlDataProvider.cs

public override Post PostSingle(int

postId)

{

using (SqlConnection

cnn = GetSqlConnection())

{

SqlCommand

cmd = cnn.CreateCommand();

cmd.CommandType = CommandType

.StoredProcedure;

cmd.CommandText = "Post_Single"

;

cmd.Parameters.Add("@PostID", SqlDbType

.Int).Value = postId;

cnn.Open();

using (SqlDataReader

reader =

cmd.ExecuteReader(CommandBehavior

.CloseConnection))

{

19

Làm ti*p các th* t*c còn l*i

// ket qua chi la 1 record nen ko dung vong

while

reader.Read();

Post p = new Post

();

p.PostID = Convert.ToInt32(reader["PostID"

]);

p.Title = reader["Title"

].ToString();

p.Body = reader["Body"

].ToString();

if (reader["Publish"] != DBNull

.Value)

p.Publish = DateTime.Parse(reader["Publish"

].ToString());

return

p;

}

Th* t*c và hàm b* sung Post_Find

SP Post_Find

CREATE PROCEDURE [dbo].

[Post_Find]

@Title nvarchar(50

)

AS

SET NOCOUNT

ON

SELECT * FROM [Post] WHERE [Title] LIKE N'%'+@Title+'%'

DataProvider.cs

public abstract List<Post> PostFind(string

title);

SqlDataProvider.cs

[email protected]

20

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider

public override List<Post> PostFind(string

title)

{

// sinh vien tu lam

}

Nh*n xét:

Các phuong th*c trong l*p SqlDataProvider s* du*c *ng d*ng g*i r*t nhi*u l*n. Ð*

tránh vi*c t*o di t*o l*i các d*i tu*ng SqlParamter, thì chúng ta s* cache (luu vào b*

nh*) d* sau này có th* dùng l*i.

Cách làm tham kh*o trong cu*n ebook ScaleNet trang 543 m*c Cache Stored

Procedure SqlParameter Objects ho*c s* d*ng l*p SqlHelper

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider

Copy t*p tin Files/ DataTools/SQLHelper.cs vào project DataAccess.

T*o 1 class SqlDataProviderV2 cho k* th*a t* l*p DataProvider và b* sung ph*n thân

cho các phuong th*c du*c k* th*a. Chèn thêm namespace

Microsoft.ApplicationBlocks.Data d* s* d*ng l*p SqlHelper

Ð*i v*i phuong th*c PostUpdate, ta thêm nhu sau:

public override int PostUpdate(Post

post)

{

return SqlHelper.ExecuteNonQuery(_ConnectionString, "Post_Update"

,

post.PostID, post.Title, post.Body, post.Publish);

}

Gi*i thích:

Phuong th*c PostUpdate * trên dùng d* g*i SP Post_Update. Ý nghia l*n lu*t c*a các

tham s* truy*n vào nhu sau

_ConnectionString:

chu*i k*t n*i

"Post_Update":

tên c*a SP mu*n g*i

post.PostID, post.Title, post.Body, post.Publish:

* cách làm tru*c thì dây

chính là giá tr* c*a các tham s* mà b*n mu*n truy*n vào 4 tham s* theo th* t* là:

@PostID, @Title, @Body, @Publish

SqlCommand

cmd = cnn.CreateCommand();

cmd.CommandType = CommandType

.StoredProcedure;

cmd.CommandText = "Post_Update"

;

cmd.Parameters.Add("@PostID", SqlDbType

.Int).Value = post.PostID;

[email protected]

21

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider

cmd.Parameters.Add("@Title", SqlDbType.NVarChar, 50).Value = post.Title;

cmd.Parameters.Add("@Body", SqlDbType.NVarChar, 4000).Value = post.Body;

(post.Publish.HasValue)

cmd.Parameters.Add("@Publish", SqlDbType.DateTime)

.Value = post.Publish.Value;

else

cmd.Parameters.Add("@Publish", SqlDbType.DateTime)

.Value = DBNull.Value;

Khi s* d*ng SqlHelper thì b*n không c*n ph*i vi*t chi ti*t nhu trên mà ch* c*n truy*n

giá tr* dúng v*i th* t* các tham s* trong SP, có nghia là

Giá tr* post.PostID *

giá tr* c*a tham s* @PostID

post.Title *

giá tr* c*a tham s* @Title

....

Tuong t* nhu cách làm trên, ph*n code b* sung cho phuong th*c PostDelete nhu sau

public override int PostDelete(Post

post)

{

}

return SqlHelper

.ExecuteNonQuery(_ConnectionString,

"Post_Delete", post.PostID);

Do 2 th* t*c Update và Delete không có tham s* nào là ouput nên cách vi*t trên không

có v*n d* gì. B*n ti*p t*c b* sung code cho phuong th*c PostAdd thì m*t s* c* nh*

x*y ra là b*n mu*n l*y giá tr* output t* SP. Cách làm nhu sau:

// Gan tu dong cac gia tri cho cac doi tuong SqlParameter

private void AssignParameterValues(SqlParameter[] commandParameters, object

[]

parameterValues)

{

if ((commandParameters == null) || (parameterValues == null

))

return

;

(commandParameters.Length != parameterValues.Length)

throw new ArgumentException(

"Parameter count does not match Parameter Value

count."

);

for (int

i = 0, j = commandParameters.Length; i < j; i++)

commandParameters[i].Value = parameterValues[i];

}

public override int PostAdd(Post

post)

{

string spName = "Post_Add"

;

// Lay cac tham so da luu trong bo nho

SqlParameter

[] parameters =

SqlHelperParameterCache

.GetSpParameterSet(_ConnectionString, spName);

// Gan cac gia tri cho cac tham so do theo dung thu tu trong SP

[email protected]

22

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider

AssignParameterValues(parameters,

new object

[] { post.PostID, post.Title, post.Body, post.Publish });

// Lay cac tham so da luu trong bo nho

int rs =

SqlHelper.ExecuteNonQuery(_ConnectionString,

CommandType.StoredProcedure, spName, parameters);

(rs > 0)

{

// Lay gia tri cua tham so @PostID

foreach (SqlParameter p in

parameters)

{

if (String.Compare(p.ParameterName, "@PostID", true

) == 0)

return (int

)p.Value;

}

return

rs;

}

Ph*n code cho các phuong th*c còn l*i

public override Post PostSingle(int

postId)

{

using (SqlDataReader reader = SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Single"

, postId))

{

reader.Read();

Post p = new Post

();

p.PostID = Convert.ToInt32(reader["PostID"

]);

p.Title = reader["Title"

].ToString();

p.Body = reader["Body"

].ToString();

if (reader["Publish"] != DBNull

.Value)

p.Publish = DateTime.Parse(reader["Publish"

].ToString());

return

p;

}

public override List<Post> PostFind(string

title)

{

using (SqlDataReader reader = SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Find"

, title))

{

List<Post> list = new List<Post

>();

while

(reader.Read())

{

Post p = new Post

();

p.PostID = Convert.ToInt32(reader["PostID"

]);

p.Title = reader["Title"

].ToString();

p.Body = reader["Body"

].ToString();

if (reader["Publish"] != DBNull

.Value)

p.Publish = DateTime.Parse(reader["Publish"

].ToString());

list.Add(p);

}

[email protected]

return

list;

}

23

S* d*ng l*p SqlHelper d* t*i uu l*p SqlDataProvider

public override List<Post

> PostAll()

{

using (SqlDataReader reader = SqlHelper

.ExecuteReader(_ConnectionString,

"Post_All"

))

{

List<Post> list = new List<Post

>();

while

(reader.Read())

{

Post p = new Post();

p.PostID = Convert.ToInt32(reader["PostID"]);

p.Title = reader["Title"].ToString();

p.Body = reader["Body"].ToString();

if (reader["Publish"] != DBNull.Value)

p.Publish = DateTime.Parse(reader["Publish"].ToString());

list.Add(p);

}

return

list;

}

}

public override int

PostCount()

{

object rs = SqlHelper.ExecuteScalar(_ConnectionString, "Post_Count"

);

return Convert

.ToInt32(rs);

}

S*a l*i code trong l*p DataProvider nhu sau, sau dó ch*y, ki*m tra k*t qu* và các b*n

s* th*y nó v*n ch*y bình thu*ng

public static DataProvider

Instance

{

get

{

if (_Instance == null

)

_Instance = new SqlDataProviderV2("ConnectionString"

);

return

_Instance;

}

}

Nh*n xét:

Ð*i v*i 3 phuong th*c Single, Find và All ph*n code tuong d*i gi*ng nhau, ch* khác *

ph*n SqlHelper

.ExecuteReader (truy*n tên th* t*c và các giá tr* cho các tham s* c*a

th* t*c).

Ph*n code tô d*m chính là ph*n trích d* li*u t* DataReader và chuy*n vào d*i tu*ng.

[email protected]

24

S* d*ng l*p CBO d* t* d*ng chuy*n d* li*u t* DataReader sang d*i tu*ng

S* d*ng l*p CBO d* t* d*ng chuy*n d* li*u t* DataReader sang d*i tu*ng

Chèn thêm thu vi*n System.Web vào project DataAccess

Copy 3 t*p tin CBO.cs, Null.cs và DataCache.cs trong thu m*c Files/DataTools vào

project DataAccess

S*a l*i code c*a 3 phuong th*c Single, All, Find trong l*p SqlDataProviderV2 nhu sau

(chèn thêm namespace Core d* s* d*ng l*p CBO)

public override Post PostSingle(int

postId)

{

return CBO.FillObject<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Single"

, postId));

}

public override List<Post> PostFind(string

title)

{

return CBO.FillCollection<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Find"

, title));

}

public override List<Post

> PostAll()

{

return CBO.FillCollection<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_All"

));

}

[email protected]

25

S* d*ng l*p CBO d* t* d*ng chuy*n d* li*u t* DataReader sang d*i tu*ng

Cách s* d*ng l*p CBO

public override Post PostSingle(int

postId)

{

return CBO.FillObject<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Single"

, postId));

}

Phuong th*c FillObject<ki*u d* li*u d*i tu*ng>( DataReader ): l*y d* li*u t*

DataReader và tr* v* m*t d*i tu*ng

public override List<Post

> PostAll()

{

return CBO.FillCollection<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_All"

));

}

Phuong th*c FillCollection< ki*u d* li*u d*i tu*ng>( DataReader ): l*y d* li*u t*

DataReader và tr* v* m*t danh sách ki*u List

Toàn b* code c*a l*p SqlDataProviderV2 du*c vi*t nhu sau:

using

System;

using

System.Collections.Generic;

using

System.Configuration;

using Microsoft.ApplicationBlocks.Data;

// namespace cua lop SqlHelper

using

System.Data;

using

System.Data.SqlClient;

using Core;

// namespace cua lop CBO

namespace

DataAccess

{

public class SqlDataProviderV2 :

DataProvider

{

private string

_ConnectionString;

public SqlDataProviderV2(string

connectionStringName)

{

_ConnectionString =

ConfigurationManager

.ConnectionStrings[connectionStringName].ConnectionString;

}

private void AssignParameterValues(SqlParameter[] commandParameters, object

[]

parameterValues)

{

if ((commandParameters == null) || (parameterValues == null

))

return

;

(commandParameters.Length != parameterValues.Length)

throw new ArgumentException(

"Parameter count does not match Parameter

Value count."

);

[email protected]

26

S* d*ng l*p CBO d* t* d*ng chuy*n d* li*u t* DataReader sang d*i tu*ng

for (int

i = 0, j = commandParameters.Length; i < j; i++)

commandParameters[i].Value = parameterValues[i];

}

public override Post PostSingle(int

postId)

{

return CBO.FillObject<Post>(SqlHelper

.ExecuteReader(_ConnectionString,

"Post_Single"

, postId));

}

public override List<Post> PostFind(string

title)

{

return

CBO.FillCollection<Post>(SqlHelper.ExecuteReader(_ConnectionString, "Post_Find"

,

title));

}

public override List<Post

> PostAll()

{

return

CBO.FillCollection<Post>(SqlHelper.ExecuteReader(_ConnectionString, "Post_All"

));

}

public override int PostAdd(Post

post)

{

string spName = "Post_Add"

;

// Lay cac tham so tu bo nho

SqlParameter

[] parameters =

SqlHelperParameterCache

.GetSpParameterSet(_ConnectionString, spName);

AssignParameterValues(parameters,

new object

[] { post.PostID, post.Title, post.Body, post.Publish });

int rs = SqlHelper

.ExecuteNonQuery(_ConnectionString,

CommandType

.StoredProcedure, spName, parameters);

(rs > 0)

{

foreach (SqlParameter p in

parameters)

{

if (String.Compare(p.ParameterName, "@PostID", true

) == 0)

return (int

)p.Value;

}

return

rs;

}

public override int PostUpdate(Post

post)

{

return SqlHelper.ExecuteNonQuery(_ConnectionString, "Post_Update"

,

post.PostID, post.Title, post.Body, post.Publish);

}

public override int PostDelete(Post

post)

{

return SqlHelper.ExecuteNonQuery(_ConnectionString, "Post_Delete"

,

post.PostID);

[email protected]

}

}

Nh*n xét:

27

Xây d*ng thu vi*n Core * m*c t*ng quát

Các phuong th*c Update, Delete tuong d*i gi*ng nhau ch* khác ph*n spName

và các giá tr* tham s*

Các phuong th*c Find, All, Single tuong d*i gi*ng nhau ch* khác ph*n spName

và các giá tr* tham s*

Ð*t v*n d*:

Gi* s* b*n có thêm m*t b*ng n*a trong CSDL, thì các thao tác d*c/ghi cung tuong t*

nhu các trên. B*n ch* c*n "cóp dán" và s*a l*i nh*ng ph*n sai khác. Nhung b*n ph*i

làm gì khi b*n mu*n xây d*ng m*t *ng d*ng khác v*i CSDL hoàn toàn khác. B*n s*

ph*i vi*t l*i ho*c copy và s*a l*i m*t s* ph*n trong project DataAccess d* phù h*p v*i

project m*i*

m*t th*i gian. Do dó d* ti*t ki*m th*i gian xây d*ng *ng d*ng, b*n nên

xây d*ng m*t thu vi*n bao g*m các l*p th*c hi*n thao tác d*c, ghi d* li*u * m*c t*ng

quát (t*m d*t là Core) có th* dùng cho nhi*u project khác nhau.

Xây d*ng thu vi*n Core * m*c t*ng quát

1. T*o thu m*c * Desktop và d*t tên là LibCore

2. M* Microsoft Visual Studio (VS), t*o m*t project thu vi*n (Class Library Project)

và d*t tên là Core

[email protected]

28

Xây d*ng thu vi*n Core * m*c t*ng quát

3. B*m chu*t ph*i References ch*n Add References, sau dó vào th* .NET d* thêm

2 thu vi*n sau

System.Configuration

System.Web

4. Xóa Class1 và copy 4 file sau vào project Core

SqlHelper.cs

CBO.cs

Null.cs

DataCache.cs

5. Thêm 2 class là DataProvider và SqlDataProvider vào project

6. Solution c*a b*n s* có 2 thu vi*n và các t*p tin nhu hình sau:

[email protected]

B* sung code cho l*p DataProvider

29

Xây d*ng thu vi*n Core * m*c t*ng quát

using

System;

using

System.Data;

namespace

DataAccess

{

public abstract class

DataProvider

{

public abstract object ExecuteNonQueryWithOutput(string outputParam,

string

spName, params object

[] parameterValues);

public abstract int ExecuteNonQuery(string spName, params object

[]

parameterValues);

public abstract DataSet ExecuteDataset(string spName, params object

[]

parameterValues);

public abstract IDataReader ExecuteReader(string spName, params object

[]

parameterValues);

public abstract object ExecuteScalar(string spName, params object

[]

parameterValues);

}

}

B* sung code cho l*p SqlDataProvider

using

System;

using

System.Configuration;

using

Microsoft.ApplicationBlocks.Data;

using

System.Data;

[email protected]

30

Xây d*ng thu vi*n Core * m*c t*ng quát

using

System.Data.SqlClient;

namespace

DataAccess

{

public class SqlDataProvider :

DataProvider

{

private string

connectionString;

public SqlDataProvider(string

connectionStringName)

{

this

.connectionString =

ConfigurationManager

.ConnectionStrings[connectionStringName].ConnectionString;

}

public override int ExecuteNonQuery(string spName, params object

[]

parameterValues)

{

return SqlHelper

.ExecuteNonQuery(connectionString, spName,

parameterValues);

}

public override object ExecuteNonQueryWithOutput(string outputParam,

string

spName, params object

[] parameterValues)

{

SqlParameter

[] parameters =

SqlHelperParameterCache

.GetSpParameterSet(connectionString, spName);

AssignParameterValues(parameters, parameterValues);

int rs = SqlHelper

.ExecuteNonQuery(connectionString,

CommandType

.StoredProcedure, spName, parameters);

if (rs > 0 && !string

.IsNullOrEmpty(outputParam))

{

foreach (var item in

parameters)

if (String.Compare(item.ParameterName, outputParam, true

) == 0)

return

item.Value;

}

return null

;

}

public override IDataReader ExecuteReader(string spName, params object

[]

parameterValues)

{

return SqlHelper

.ExecuteReader(connectionString, spName,

parameterValues);

}

public override DataSet ExecuteDataset(string spName, params object

[]

parameterValues)

{

return SqlHelper

.ExecuteDataset(connectionString, spName,

parameterValues);

}

public override object ExecuteScalar(string spName, params object

[]

parameterValues)

[email protected]

31

Xây d*ng thu vi*n Core * m*c t*ng quát

{

return SqlHelper

.ExecuteScalar(connectionString, spName,

parameterValues);

}

private void AssignParameterValues(SqlParameter[] commandParameters, object

[]

parameterValues)

{

if ((commandParameters == null) || (parameterValues == null

))

return

;

(commandParameters.Length != parameterValues.Length)

throw new ArgumentException(

"Parameter count does not match Parameter

Value count."

);

for (int

i = 0, j = commandParameters.Length; i < j; i++)

commandParameters[i].Value = parameterValues[i];

}

}

B* sung ti*p code cho l*p DataProvider

private static DataProvider instance = null

;

public static DataProvider

Instance

{

get

{

if (instance == null

)

instance = new SqlDataProvider("ConnectionString"

);

return

instance;

}

}

Toàn b* code c*a l*p DataProvider nhu sau

using

System;

using

System.Data;

namespace

DataAccess

{

public abstract class

DataProvider

{

private static DataProvider instance = null

;

public static DataProvider

Instance

{

get

{

if (instance == null

)

instance = new SqlDataProvider("ConnectionString"

);

return

instance;

}

[email protected]

32

Xây d*ng thu vi*n DataAccess s* d*ng thu vi*n Core.dll

public abstract object ExecuteNonQueryWithOutput(string outputParam,

string

spName, params object

[] parameterValues);

public abstract int ExecuteNonQuery(string spName, params object

[]

parameterValues);

public abstract DataSet ExecuteDataset(string spName, params object

[]

parameterValues);

public abstract IDataReader ExecuteReader(string spName, params object

[]

parameterValues);

public abstract object ExecuteScalar(string spName, params object

[]

parameterValues);

}

}

B*m Ctrl + Shilft + B d* build project, sau dó vào thu m*c bin d* l*y file thu vi*n

Core.dll

Xây d*ng thu vi*n DataAccess s* d*ng thu vi*n Core.dll

1. Vào menu File > Add > New Project vào t*o m*t project thu vi*n (Class Library

Project) và d*t tên là DataAccess

[email protected]

33

Xây d*ng thu vi*n DataAccess s* d*ng thu vi*n Core.dll

2. Xóa Class1 và thêm thu vi*n Core vào project DataAccess.

3. T*o l*p Post nhu sau

using

System;

using

System.Collections.Generic;

using

Core;

namespace

DataAccess

{

public class

Post

{

public int PostID { get; set

; }

public string Title { get; set

; }

public string Body { get; set

; }

public DateTime? Publish { get; set

; }

public

Post() { }

public static List<Post

> All()

{

return CBO.FillCollection<Post

>(

DataProvider.Instance.ExecuteReader("Post_All"

));

}

public static List<Post> Find(string

title)

{

return CBO.FillCollection<Post

>(

DataProvider.Instance.ExecuteReader("Post_Find"

, title));

}

public static Post Single(string

postId)

{

try

{

return CBO.FillObject<Post

>(

DataProvider.Instance.ExecuteReader("Post_Single"

,

Convert

.ToInt32(postId)));

}

catch (Exception

)

{

return null

;

}

public static int

Count()

{

object rs = DataProvider.Instance.ExecuteScalar("Post_Count"

);

return Convert

.ToInt32(rs);

}

public static int Add(Post

data)

{

[email protected]

34

Xây d*ng thu vi*n DataAccess s* d*ng thu vi*n Core.dll

object

rs =

DataProvider.Instance.ExecuteNonQueryWithOutput("@PostID", "Post_Add"

,

data.PostID, data.Title, data.Body, data.Publish);

int identity = rs != null ? Convert

.ToInt32(rs) : 0;

return

identity;

}

public static bool Update(Post

data)

{

int rs = DataProvider.Instance.ExecuteNonQuery("Post_Update"

,

data.PostID, data.Title, data.Body, data.Publish);

return

rs > 0;

}

public static bool Delete(string

postId)

{

try

{

int rs = DataProvider.Instance.ExecuteNonQuery("Post_Delete"

,

Convert

.ToInt32(postId));

return

rs > 0;

}

catch (Exception

)

{

return false

;

}

4. T*o ti*p project Console và test nhu vi d* trên

[email protected]

Luy*n t*p

1. T*o b*ng nhu sau, thi*t l*p c*t Id có giá tr* id t* tang, d*t tên là Movie

2. Thêm d* li*u cho b*ng Movie

M* file SrciptSQL/Movie_Data.sql, ch*n database ch*a b*ng Movie sau dó b*m

Execute

Database ch*a b*ng Movie

3. T*o thu vi*n Data Access nhu ph*n tru*c d* g*i các th* t*c sau (t*o ti*p l*p

Movie và b* sung các phuong th*c vào project * trên). Sau m*i phuong th*c

ph*i test k*t qu* trong project Consolde

[email protected]

35

Luy*n t*p

Movie_All

Movie _Single

Movie _Find

Movie _Add

Movie _Update

Movie _Delete

Movie _Count

Movie_Paging

Hu*ng d*n làm th* t*c Movie_Paging

1. B*m vào New Query, gõ l*n lu*t các câu truy v*n sau và xem k*t qu*

Câu 1: thêm m*t c*t s* th* t* vào b*ng k*t qu* ( hàm ROW_NUMBER()

ch* s*

d*ng * các b*n SQL Server 2005 tr* lên)

SELECT ROW_NUMBER() OVER (ORDER BY Id) AS Row,

Title

FROM

Movie

Câu 2: l*y các k*t qu* t* hàng th* 6 *

10

SELECT Row,

Title

FROM

(

SELECT ROW_NUMBER() OVER (ORDER BY Id) AS Row,

Title

FROM

Movie

) AS

MoviesWithRowNumbers

[email protected]

36

Luy*n t*p

WHERE Row >= 6 AND Row <=

10

Câu 3: t*o m*t b*ng t*m (@Movies) có kèm theo c*t th* t* d* luu d* li*u t*m

vào dó, sau dó l*y các hàng t* 6 * 10 trong b*ng t*m *

cách làm này g*i là phân

trang (Paging)

S* d*ng SQL 2005 tr* di

-- declare a new TABLE variable

DECLARE @Movies

TABLE

(

RowNumber INT

,

Id INT

,

Title NVARCHAR(100

)

-- populate the table variable with the complete list of products

INSERT INTO

@Movies

SELECT ROW_NUMBER() OVER (ORDER BY Movie.Id) AS Row

,

Id,

Title

FROM

Movie

-- extract the requested page of products

SELECT * FROM

@Movies

WHERE RowNumber >= 6 AND RowNumber <=

10

S* d*ng SQL Server 2000

DECLARE @Movies

TABLE

(

RowNumber INT IDENTITY (1,1

),

Id INT

,

Title NVARCHAR(100

)

-- populate the table variable with the complete list of products

INSERT INTO

@Movies

SELECT Id,

Title

FROM

Movie

-- extract the requested page of products

SELECT * FROM

@Movies

WHERE RowNumber >= 6 AND RowNumber <=

10

[email protected]

37

Luy*n t*p

K*t qu* t* câu truy v*n 3 (ch* l*y 3 c*t)

Tuong t* nhu trên, vi*t thêm vào câu truy v*n 3 d* l*y d*y d* các c*t c*a b*ng

Movie

Câu 4: L*y d* li*u t* dòng 1 *

5 (trang 1, s* record t*i da trong 1 trang là 5)

DECLARE @PageNumber INT

DECLARE @PageSize INT

SET @PageNumber = 1 -- trang hien tai

SET @PageSize = 5 -- so record toi da cua mot trang

-- tao bang tam de chua du lieu

DECLARE @Movies

TABLE

(

RowNumber INT

,

Id INT

,

Title NVARCHAR(100

),

Director NVARCHAR(100

),

DateReleased DATETIME

,

InTheaters BIT

,

BoxOfficeTotals MONEY

,

Description NVARCHAR(4000

)

-- dua du lieu vao bang movie kem theo cot stt

INSERT INTO

@Movies

SELECT ROW_NUMBER() OVER (ORDER BY Movie.Id) AS Row

,

Id, Title, Director, DateReleased, InTheaters, BoxOfficeTotals

,

Description

FROM

Movie

-- tong so record cua bang tam @Movies

SELECT COUNT(Id) FROM @Movies

-- lay cac record can thiet

SELECT * FROM @Movies

WHERE RowNumber > (@PageNumber -1) * @PageSize

AND RowNumber <= @PageNumber * @PageSize

S* d*ng SQL Server 2000

[email protected]

38

Luy*n t*p

DECLARE @PageNumber

INT

DECLARE @PageSize

INT

SET @PageNumber = 1

-- trang hien tai

SET @PageSize = 5

-- so record toi da cua mot trang

-- tao bang tam de chua du lieu

DECLARE @Movies

TABLE

(

RowNumber INT IDENTITY (1,1

),

Id INT

,

Title NVARCHAR(100

),

Director NVARCHAR(100

),

DateReleased DATETIME

,

InTheaters BIT

,

BoxOfficeTotals MONEY

,

Description NVARCHAR(4000

)

-- dua du lieu vao bang movie kem theo cot stt

INSERT INTO @Movies

SELECT Id, Title, Director, DateReleased, InTheaters, BoxOfficeTotals,

Description

FROM Movie

-- tong so record cua bang tam @Movies

SELECT COUNT(Id) FROM

@Movies

-- lay cac record can thiet

SELECT * FROM

@Movies

WHERE RowNumber > (@PageNumber -1) *

@PageSize

AND RowNumber <= @PageNumber * @PageSize

K*t qu* truy v*n nhu sau

B*ng 1: t*ng s* record. T* t*ng s* record này, b*n có th* tính du*c t*ng s*

trang theo công th*c

So Trang = Làm tròn lên( TongRecord / PageSize )

B*ng 2: ph*n d* li*u c*a trang 1

[email protected]

39

Luy*n t*p

Câu 5: Tuong t* thay @PageNumber = 2 và xem k*t qu*

SET @PageNumber = 2 -- trang hien tai

Áp d*ng vi*t th* t*c Movie_Paging nhu sau

CREATE PROCEDURE

Movie_Paging

@PageNumber INT

,

@PageSize

INT

AS

-- tao bang tam de chua du lieu

DECLARE @Movies

TABLE

(

RowNumber INT

,

Id INT

,

Title NVARCHAR(100

),

Director NVARCHAR(100

),

DateReleased DATETIME

,

InTheaters BIT

,

BoxOfficeTotals MONEY

,

Description NVARCHAR(4000

)

-- dua du lieu vao bang movie kem theo cot stt

INSERT INTO

@Movies

SELECT ROW_NUMBER() OVER (ORDER BY Movie.Id) AS Row

,

Id, Title, Director, DateReleased, InTheaters, BoxOfficeTotals

,

Description

FROM

Movie

-- tong so record cua bang tam @Movies

SELECT COUNT(Id) FROM @Movies

-- lay cac record can thiet

SELECT * FROM @Movies

WHERE RowNumber > (@PageNumber -1) * @PageSize

AND RowNumber <= @PageNumber * @PageSize

SQL Server 2000

CREATE PROCEDURE

Movie_Paging

@PageNumber INT

,

@PageSize

INT

AS

-- tao bang tam de chua du lieu

DECLARE @Movies

TABLE

(

RowNumber INT IDENTITY (1,1

),

Id INT

,

Title NVARCHAR(100

),

Director NVARCHAR(100

),

DateReleased DATETIME

,

[email protected]

40

Luy*n t*p

InTheaters BIT

,

BoxOfficeTotals MONEY

,

Description NVARCHAR(4000

)

-- dua du lieu vao bang movie kem theo cot stt

INSERT INTO

@Movies

SELECT Id, Title, Director, DateReleased, InTheaters, BoxOfficeTotals

,

Description

FROM

Movie

-- tong so record cua bang tam @Movies

SELECT COUNT(Id) FROM

@Movies

-- lay cac record can thiet

SELECT * FROM

@Movies

WHERE RowNumber > (@PageNumber -1) *

@PageSize

AND RowNumber <= @PageNumber *

@PageSize

Vi*t phuong th*c Paging trong l*p Movie nhu sau

public static List<Movie> Paging(int page, int pageSize, out int

howManyPages)

{

IDataReader reader = null

;

try

{

reader = DataProvider

.Instance.ExecuteReader(

"Movie_Paging"

, page, pageSize);

//lay du lieu tu bang 1

reader.Read();

//tinh so trang

howManyPages = (int)Math.Ceiling((double

)reader.GetInt32(0) /

(double

)pageSize);

//lay du lieu tu bang 2

reader.NextResult();

return CBO.FillCollection<Product

>(reader);

}

catch

{

// dam bao ket noi duoc dong neu co loi xay ra

if (reader != null && reader.IsClosed == false

)

reader.Close();

// so trang = 0

howManyPages = 0;

// tra ve ket qua la mot ds rong

return new List<Product

>();

}

[email protected]

41

Luy*n t*p

Bạn đang đọc truyện trên: Truyen247.Pro

Trước Sau

Tags: #123 #1234 #canh #truong #until #you20027