dbproviderfactories.getfactory mysql_asp.net下使用DbProviderFactories的数据库操作类
封装数据库操作,并且提供事务处理。
使用DbProviderFactories的数据库操作类
Imports System.Data
Imports System.Configuration
Imports System.Data.Common
'*******************************************************************
'* Page/Class Name:XPDBHelper.vb
'* Title:使用DbProviderFactories的数据库操作类
'* Description:简单三层结构数据库操作类
'* Copyright:
'* Company:
'* @author:Owen,Yuan
'* Create Date:2010/3/9 14:04:56
'* Last Modifier:
'* Last Modify Date:
'*******************************************************************
Public Class XPDBHelper
'取得连接字符串中的数据库驱动提供者
Private Shared dbProviderName As String = ConfigurationManager.ConnectionStrings("ConnectionString").ProviderName
'取得数据库连接字符串
Private Shared dbConnectionString As String = ConfigurationManager.ConnectionStrings("ConnectionString").ConnectionString
'数据库连接。
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
'创建数据库连接
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
'创建数据库连接
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
'根据存储过程创建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
'根据SQL语句创建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 "增加参数"
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 "执行"
'执行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
'执行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
'执行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 "执行事务"
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
简单三层结构数据库事务处理类
Imports System.Data
Imports System.Data.Common
'*******************************************************************
'* Page/Class Name:XPTransaction.vb
'* Title:数据库事务处理类
'* Description:简单三层结构数据库事务处理类
'* 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 ' 检测冗余的调用
' IDisposable
Protected Overridable Sub Dispose(ByVal disposing As Boolean)
If Not Me.disposedValue Then
If disposing Then
conn.Close()
' TODO: 释放其他状态(托管对象)。
End If
conn = Nothing
dbTrans = Nothing
' TODO: 释放您自己的状态(非托管对象)。
' TODO: 将大型字段设置为 null。
End If
Me.disposedValue = True
End Sub
#Region " IDisposable Support "
' Visual Basic 添加此代码是为了正确实现可处置模式。
Public Sub Dispose() Implements IDisposable.Dispose
' 不要更改此代码。请将清理代码放入上面的 Dispose(ByVal disposing As Boolean) 中。
Dispose(True)
GC.SuppressFinalize(Me)
End Sub
#End Region
End Class
dbproviderfactories.getfactory mysql_asp.net下使用DbProviderFactories的数据库操作类相关推荐
- nodeJS下利用mongdb进行数据库操作
2019独角兽企业重金招聘Python工程师标准>>> 需要引用的node_modules npm install mongodb 此处引用的mongodb模块版本为1.4.12 一 ...
- mvc5 ef mysql_ASP.NET MVC快速入门之数据库操作(MVC5+EF6)[第一篇][上] | Rickytsang洛水寒...
新建项目 打开VS2015,找到菜单项[文件->新建->项目],打开向导对话框: 注意我们的选择项: 运行平台:.NET FrameWork 4.5 项目模板:ASP.NET Web Ap ...
- discuz php mysql_php下mysql数据库操作类(改自discuz)
/* -------------------------------- System:PT book - PT小说小偷 Code: 杰少Pakey -------------------------- ...
- DbHelper数据操作类,DbProviderFactories
其实,微软的企业库中有一个非常不错的数据操作类了.但是,不少公司(起码我遇到的几个...),对一些"封装"了些什么的东西不太敢用,虽然我推荐过微软的企业库框架了...但是还是要&q ...
- mysql DbProviderFactories.GetFactory失败,解决方法
DbProviderFactories.GetFactory 获取mysql不成功, 添加配置文件 <system.data> <DbProviderFactories > & ...
- windows10 oracle自动备份,Windows系统下oracle 自动备份数据库
Windows系统下oracle 自动备份数据库 1.创建批处理文件(.bat) 2.建立windows 定时任务 2.1创建任务 2.2 常规处 ->填写任务名称 2.3触发器 2.4 操作 ...
- classlist使用方法_如何通过使用HTML5的classList API在没有jQuery的情况下操作类
classlist使用方法 by Ayo Isaiah 通过Ayo Isaiah 如何通过使用HTML5的classList API在没有jQuery的情况下操作类 (How to manipulat ...
- java 无锁缓存_如何在高并发环境下设计出无锁的数据库操作(Java版本)
一个在线2k的游戏,每秒钟并发都吓死人.传统的hibernate直接插库基本上是不可行的.我就一步步推导出一个无锁的数据库操作. 1. 并发中如何无锁. 一个很简单的思路,把并发转化成为单线程.Jav ...
- Linux下定时切割Mongodb数据库日志并删除指定天数前的日志记录(转)
文章转自:http://www.osyunwei.com/archives/8998.html 说明: 操作系统:CentOS Mongodb安装目录:/usr/local/mongodb Mongo ...
最新文章
- 小程序给视频加默认图片封面,点击播放视频并停止播放上一个视频
- Linux下利用backtrace追踪函数调用堆栈以及定位段错误【转】
- mysql 上一条 下一条,MYSQL实现上一条下一条功能
- python流程图-使用Graphviz快速绘制流程图
- 全文索引 排名计算问题
- 信息技术与计算机文化的问题,信息技术与计算机文化
- 【转载】ACM中矩阵乘法的应用
- angular1 搜索服务 ,震灾名称是必填
- 美国科技股昨日普遍下跌:华尔街受特朗普影响抛售科技股票
- 30岁了还可以学java吗_30岁还能零基础学Java吗?
- PS:修复图片模糊(字体)
- 【实习日报】2019年4月下半月 前端开发实习工作日报汇总
- OEEL——使用OEEL快速画出精美图案(以土地利用转移变化为例)
- 连接服务器显示凭据,连接云服务器时的凭据是什么意思
- 自定义json格式-解析为对象
- 【H5】html5的新增的标签和废除的标签
- html5如何实现无序排列,无序列表让li横排
- 又一所“一流大学”北京航空航天大学和华为签约
- MSS总体流程图(十)
- dhrystone和coremark测试比较
热门文章
- 码农的自我修炼之路-----BST
- 如何为 SQL Server 2000 分发和安装 SQL-DMO(引用)
- 成就架构师,到底是怎样的一种体验?
- JEECG再创新举,开辟云应用开发新时代,打造jeecg企业级云应用生态圈
- hibernate映射数据库表如何在不插入值的情况下使表中字段默认值生效
- MappingException:class com.zsn.crm.Model.user not found whie looking for property user id
- Kubernetes中使用CronJob定时备份etcd集群数据
- mysql视图使用方法
- 一个memset函数使用时的坑
- javascript 参数检验(二):参数检查工具的完善