Đọc truyện hoc tap

♥ AzTruyen.Top - Trang đọc truyện hoàn toàn miễn phí!

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: AzTruyen.Top

Trước Sau

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