封裝數(shù)據(jù)庫操作，并且提供事務(wù)處理。

使用DbProviderFactories的數(shù)據(jù)庫操作類

Imports System.Data

Imports System.Configuration

Imports System.Data.Common

'*******************************************************************

'* Page/Class Name：XPDBHelper.vb

'* Title：使用DbProviderFactories的數(shù)據(jù)庫操作類

'* Description：簡單三層結(jié)構(gòu)數(shù)據(jù)庫操作類

'* Copyright：

'* Company：

'* @author：Owen,Yuan

'* Create Date：2010/3/9 14:04:56

'* Last Modifier：

'* Last Modify Date：

'*******************************************************************

Public Class XPDBHelper

'取得連接字符串中的數(shù)據(jù)庫驅(qū)動提供者

Private Shared dbProviderName As String = ConfigurationManager.ConnectionStrings("ConnectionString").ProviderName

'取得數(shù)據(jù)庫連接字符串

Private Shared dbConnectionString As String = ConfigurationManager.ConnectionStrings("ConnectionString").ConnectionString

'數(shù)據(jù)庫連接。

Private connection As DbConnection

Public Sub New()

Me.connection = CreateConnection(XPDBHelper.dbConnectionString)

End Sub

Public Sub New(ByVal connectionString As String)

Me.connection = CreateConnection(connectionString)

End Sub

'創(chuàng)建數(shù)據(jù)庫連接

Public Shared Function CreateConnection() As DbConnection

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(dbProviderName)

Dim dbconn As DbConnection = dbfactory.CreateConnection()

dbconn.ConnectionString = XPDBHelper.dbConnectionString

Return dbconn

End Function

'創(chuàng)建數(shù)據(jù)庫連接

Public Shared Function CreateConnection(ByVal connectionString As String) As DbConnection

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(dbProviderName)

Dim dbconn As DbConnection = dbfactory.CreateConnection()

dbconn.ConnectionString = connectionString

Return dbconn

End Function

'根據(jù)存儲過程創(chuàng)建DbCommand

Public Function GetStoredProcCommond(ByVal storedProcedure As String) As DbCommand

Dim dbCommand As DbCommand = connection.CreateCommand()

dbCommand.CommandText = storedProcedure

dbCommand.CommandType = CommandType.StoredProcedure

Return dbCommand

End Function

'根據(jù)SQL語句創(chuàng)建DbCommand

Public Function GetSqlStringCommond(ByVal sqlQuery As String) As DbCommand

Dim dbCommand As DbCommand = connection.CreateCommand()

dbCommand.CommandText = sqlQuery

dbCommand.CommandType = CommandType.Text

Return dbCommand

End Function

#Region "增加參數(shù)"

Public Sub AddParameterCollection(ByVal cmd As DbCommand, ByVal dbParameterCollection As DbParameterCollection)

For Each dbParameter As DbParameter In dbParameterCollection

cmd.Parameters.Add(dbParameter)

Next

End Sub

Public Sub AddOutParameter(ByVal cmd As DbCommand, ByVal parameterName As String, ByVal dbType As DbType, ByVal size As Integer)

Dim dbParameter As DbParameter = cmd.CreateParameter()

dbParameter.DbType = dbType

dbParameter.ParameterName = parameterName

dbParameter.Size = size

dbParameter.Direction = ParameterDirection.Output

cmd.Parameters.Add(dbParameter)

End Sub

Public Sub AddInParameter(ByVal cmd As DbCommand, ByVal parameterName As String, ByVal dbType As DbType, ByVal value As Object)

Dim dbParameter As DbParameter = cmd.CreateParameter()

dbParameter.DbType = dbType

dbParameter.ParameterName = parameterName

dbParameter.Value = value

dbParameter.Direction = ParameterDirection.Input

cmd.Parameters.Add(dbParameter)

End Sub

Public Sub AddReturnParameter(ByVal cmd As DbCommand, ByVal parameterName As String, ByVal dbType As DbType)

Dim dbParameter As DbParameter = cmd.CreateParameter()

dbParameter.DbType = dbType

dbParameter.ParameterName = parameterName

dbParameter.Direction = ParameterDirection.ReturnValue

cmd.Parameters.Add(dbParameter)

End Sub

Public Function GetParameter(ByVal cmd As DbCommand, ByVal parameterName As String) As DbParameter

Return cmd.Parameters(parameterName)

End Function

#End Region

#Region "執(zhí)行"

'執(zhí)行DbCommand，返回DataSet

Public Function ExecuteDataSet(ByVal cmd As DbCommand) As DataSet

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(dbProviderName)

Dim dbDataAdapter As DbDataAdapter = dbfactory.CreateDataAdapter()

dbDataAdapter.SelectCommand = cmd

Dim ds As DataSet = New DataSet()

dbDataAdapter.Fill(ds)

Return ds

End Function

'執(zhí)行DbCommand，返回DataTable

Public Function ExecuteDataTable(ByVal cmd As DbCommand) As DataTable

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(dbProviderName)

Dim dbDataAdapter As DbDataAdapter = dbfactory.CreateDataAdapter()

dbDataAdapter.SelectCommand = cmd

Dim dataTable As DataTable = New DataTable()

dbDataAdapter.Fill(dataTable)

Return dataTable

End Function

'執(zhí)行DbCommand，返回DbDataReader

Public Function ExecuteReader(ByVal cmd As DbCommand) As DbDataReader

cmd.Connection.Open()

Dim reader As DbDataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection)

cmd.Connection.Close()

Return reader

End Function

Public Function ExecuteNonQuery(ByVal cmd As DbCommand) As Integer

cmd.Connection.Open()

Dim ret As Integer = cmd.ExecuteNonQuery()

cmd.Connection.Close()

Return ret

End Function

Public Function ExecuteScalar(ByVal cmd As DbCommand) As Object

cmd.Connection.Open()

Dim ret As Object = cmd.ExecuteScalar()

cmd.Connection.Close()

Return ret

End Function

#End Region

#Region "執(zhí)行事務(wù)"

Public Function ExecuteDataSet(ByVal cmd As DbCommand, ByVal t As XPTransaction) As DataSet

cmd.Connection = t.DbConnection

cmd.Transaction = t.DbTransact

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(XPDBHelper.dbProviderName)

Dim dbDataAdapter As DbDataAdapter = dbfactory.CreateDataAdapter()

dbDataAdapter.SelectCommand = cmd

Dim ds As DataSet = New DataSet()

dbDataAdapter.Fill(ds)

Return ds

End Function

Public Function ExecuteDataTable(ByVal cmd As DbCommand, ByVal t As XPTransaction) As DataTable

cmd.Connection = t.DbConnection

cmd.Transaction = t.DbTransact

Dim dbfactory As DbProviderFactory = DbProviderFactories.GetFactory(XPDBHelper.dbProviderName)

Dim dbDataAdapter As DbDataAdapter = dbfactory.CreateDataAdapter()

dbDataAdapter.SelectCommand = cmd

Dim dataTable As DataTable = New DataTable()

dbDataAdapter.Fill(dataTable)

Return dataTable

End Function

Public Function ExecuteReader(ByVal cmd As DbCommand, ByVal t As XPTransaction) As DbDataReader

cmd.Connection.Close()

cmd.Connection = t.DbConnection

cmd.Transaction = t.DbTransact

Dim reader As DbDataReader = cmd.ExecuteReader()

Return reader

End Function

Public Function ExecuteNonQuery(ByVal cmd As DbCommand, ByVal t As XPTransaction) As Integer

cmd.Connection.Close()

cmd.Connection = t.DbConnection

cmd.Transaction = t.DbTransact

Return cmd.ExecuteNonQuery()

End Function

Public Function ExecuteScalar(ByVal cmd As DbCommand, ByVal t As XPTransaction) As Object

cmd.Connection.Close()

cmd.Connection = t.DbConnection

cmd.Transaction = t.DbTransact

Return cmd.ExecuteScalar()

End Function

#End Region

End Class

簡單三層結(jié)構(gòu)數(shù)據(jù)庫事務(wù)處理類

Imports System.Data

Imports System.Data.Common

'*******************************************************************

'* Page/Class Name：XPTransaction.vb

'* Title：數(shù)據(jù)庫事務(wù)處理類

'* Description：簡單三層結(jié)構(gòu)數(shù)據(jù)庫事務(wù)處理類

'* Copyright：

'* Company：

'* @author：Owen,Yuan

'* Create Date：2010/3/22 10:44:20

'* Last Modifier：

'* Last Modify Date：

'*******************************************************************

Public Class XPTransaction

Implements IDisposable

Private conn As DbConnection

Private dbTrans As DbTransaction

Public Property DbConnection() As DbConnection

Get

Return Me.conn

End Get

Set(ByVal Value As DbConnection)

Me.conn = Value

End Set

End Property

Public Property DbTransact() As DbTransaction

Get

Return Me.dbTrans

End Get

Set(ByVal Value As DbTransaction)

Me.dbTrans = Value

End Set

End Property

Public Sub New()

conn = XPDBHelper.CreateConnection()

conn.Open()

dbTrans = conn.BeginTransaction()

End Sub

Public Sub New(ByVal connectionString As String)

conn = XPDBHelper.CreateConnection(connectionString)

conn.Open()

dbTrans = conn.BeginTransaction()

End Sub

Public Sub Commit()

dbTrans.Commit()

Me.Colse()

End Sub

Public Sub RollBack()

dbTrans.Rollback()

Me.Colse()

End Sub

Public Sub Colse()

If conn.State = ConnectionState.Open Then

conn.Close()

End If

End Sub

Private disposedValue As Boolean = False ' 檢測冗余的調(diào)用

' IDisposable

Protected Overridable Sub Dispose(ByVal disposing As Boolean)

If Not Me.disposedValue Then

If disposing Then

conn.Close()

' TODO: 釋放其他狀態(tài)(托管對象)。

End If

conn = Nothing

dbTrans = Nothing

' TODO: 釋放您自己的狀態(tài)(非托管對象)。

' TODO: 將大型字段設(shè)置為 null。

End If

Me.disposedValue = True

End Sub

#Region " IDisposable Support "

' Visual Basic 添加此代碼是為了正確實現(xiàn)可處置模式。

Public Sub Dispose() Implements IDisposable.Dispose

' 不要更改此代碼。請將清理代碼放入上面的 Dispose(ByVal disposing As Boolean) 中。

Dispose(True)

GC.SuppressFinalize(Me)

End Sub

#End Region

End Class

總結(jié)

以上是生活随笔為你收集整理的dbproviderfactories.getfactory mysql_asp.net下使用DbProviderFactories的数据库操作类的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。