数据库事务简介
数据库事务是由一组 SQL 语句组成的一个逻辑工作单元。您可以把事务看作是一组不可分的 SQL 语句,这些语句作为一个整体永久记录在数据库中或一并撤销。比如在银行帐户之间转移资金:一条 UPDATE语句将从一个帐户的资金总数中减去一部分,另一条 UPDATE语句将把资金加到另一个帐户中。减操作和加操作必须永久记录在数据库中,或者必须一并撤销 — 否则将损失资金。这个简单的示例仅使用了两条 UPDATE 语句,但一个更实际的事务可能包含许多 INSERT、UPDATE和 DELETE 语句。
要永久记录一个事务中的 SQL 语句的结果,您可以通过 COMMIT 语句来执行提交。要撤销 SQL 语句的结果,您可以使用 ROLLBACK 语句来执行回滚,这会把所有的行重设为它们原来的状态。只要您事先没有与数据库断开,则您在执行回滚之前所做的任何修改都将被撤销。您还可以设置一个保存点,以便将事务回滚至该特定的点,同时保持事务中的其他语句原封不动。
使用数据库事务(主要针对VB.net)
您可以使用 OracleTransaction 类的一个对象来表示一个事务。OracleTransaction 类包含多个属性,其中的两个为 Connection(指定与事务关联的数据库连接)和 IsolationLevel(指定事务隔离级别)
Connection,指定与该事务关联的OracleConnection对象;
IsolationLevel,指定该事务的IsolationLevel;枚举类型,用于对事物的锁定,取值有Chaos、ReadCommited、ReadUncommited、RepeatableRead、Serializable、Unspecified。
应用程序通过针对OracleConnection对象调用 BeginTransaction 来创建OracleTransaction对象。对OracleTransaction对象执行与该事务关联的所有后续操作(例如提交或中止该事务)。
Commit:提交SQL数据库事务;
Rollback :从挂起状态回滚事务;
您还可以使用 Save() 在事务中设置一个保存点。
下面的示例创建一个 OracleConnection 和一个 OracleTransaction。它还演示了如何使用 BeginTransaction、Commit 和 Rollback 方法。(这是MSDN里的范例)
需要注意的是,这些操作需要引入命名空间: Oracle.DataAcess.Client
Oracle.DataAccess.Client 命名空间是 ODP.NET 的一部分,它包含许多类,其中有 OracleConnection、OracleCommand 和 OracleTransaction。示例程序就用到了这些类。
事务操作
1Public Sub RunOracleTransaction()Sub RunOracleTransaction(myConnString As String)
2 Dim myConnection As New OracleConnection(myConnString)
3 myConnection.Open()
4
5 Dim myCommand As OracleCommand = myConnection.CreateCommand()
6 Dim myTrans As OracleTransaction
7
8 ' Start a local transaction
9 myTrans = myConnection.BeginTransaction(IsolationLevel.ReadCommitted)
10 ' Assign transaction object for a pending local transaction
11 myCommand.Transaction = myTrans
12
13 Try
14 myCommand.CommandText = "INSERT INTO Dept (DeptNo, Dname, Loc) values (50, 'TECHNOLOGY', 'DENVER')"
15 myCommand.ExecuteNonQuery()
16 myCommand.CommandText = "INSERT INTO Dept (DeptNo, Dname, Loc) values (60, 'ENGINEERING', 'KANSAS CITY')"
17 myCommand.ExecuteNonQuery()
18 myTrans.Commit()
19 Console.WriteLine("Both records are written to database.")
20 Catch e As Exception
21 myTrans.Rollback()
22 Console.WriteLine(e.ToString())
23 Console.WriteLine("Neither record was written to database.")
24 Finally
25 myConnection.Close()
26 End Try
27End Sub
28
在 .NET 程序中设置事务保存点
正如本文前面所提到的那样,您可以设置一个保存点,以便将事务回滚至该特定的点,同时保持事务中的其他语句原封不动。您可以使用 OracleTransaction 类的 Save() 方法在事务中设置保存点。
如果您有一个非常长的事务并且希望能够仅回滚到某个特定的时间点,那么您可能要使用保存点。例如,您可能想对 10 个产品做一些更改,然后设置一个保存点,然后再对另 10 个产品做更改;如果您在进行第二批更改时出现了错误,那么您可以回滚至保存点,使您的第一批更改原封不动。
使用OracleTransaction对象需要注意的几点:
1)你需要在你整个事务执行中只能有唯一OracleConnection ,OracleCommand,
OracleTransaction,也就是说如果你事务处理过程中如果需要与数据库的操作都只能在这唯一的Command中执行,类似于:
imgCommand.CommandText = sSQL
imgCommand.ExecuteNonQuery()或其他操作
若你新建一个连接执行其他数据库操作的话,整个事务过程就会抛出异常
2)如果你需要在你SQL语句中加入参数,则你必须在你执行完提交或相关数据库操作之后将其Command的参数清空,下边举一个实际的项目里的事务函数:
事务函数
1 ''' <summary>
2 ''' 保存热点文本文件信息到数据库
3 ''' </summary>
4 Private Function SaveTextFile()Function SaveTextFile() As Boolean
5 Dim sSQl As String
6 sSQl = "select type_id from sys_file_type where file_extname='TXT'"
7 Try
8 imgCommand.CommandText = sSQl
9 Dim typeID As Int32 = Convert.ToInt32(imgCommand.ExecuteScalar()) '文件类型
10 '读取文本信息
11 Dim Textblob() As Byte = GetText()
12
13 sSQl = "insert into t_watch_textcontent(image_id,text_content,type_id) values(:imageid,:textcontent,:typeid)"
14 '增添SQL参数
15 Dim Param As OracleClient.OracleParameter
16 Param = New OracleClient.OracleParameter("imageid", sNewImageID)
17 imgCommand.Parameters.Add(Param)
18 Param = New OracleClient.OracleParameter("textcontent", Textblob)
19 imgCommand.Parameters.Add(Param)
20 Param = New OracleClient.OracleParameter("typeid", typeID)
21 imgCommand.Parameters.Add(Param)
22
23 '提交信息
24 imgCommand.CommandText = sSQl
25 If imgCommand.ExecuteNonQuery() > 0 Then
26 bResult = True
27 '关键是这里,需要你手动清除参数
28 imgCommand.Parameters.Clear()
29 End If
30 Catch ex As Exception
31 Me.ExceptionMessage = ex
32 bResult = False
33 End Try
34
35 Return bResult
36 End Function
开始事务:
提交:
回滚:
在事件内进行SQL语句相关执行:
要注意的是,在事务进行中,不能再对同一个数据库连接(OracleConnection)再进行事务外的数据的查询和读取,也就是说,类似下边的语句是不能执行的:
而是得加一条语句,在事务内进行查询:
BTW: 转载一些资料:
特郁闷的一件事情,费时费力!记下来,为后来者铺路。
首先,我用VS2010开发对oracle10g数据库的操作,结果发现微软自带的System.Data.OracleClient已经有一些常用对象提示过时;网上说最好用Oracle自带的ODP.NET操作。
我到oracle网站下载ODAC这个安装包,还注册了用户名,200多M,而且下载特慢,下载后结果是调试了很久都不行。
其次,问用oracle的同事,告诉我安装了oracle客户端后在安装目录下有ODP.Net的DLL,直接引用那个就OK了;我在我的oracle客户端安装录D:\oracle\product\10.2.0\db_1\BIN下真的还找到了 Oracle.DataAccess.dll。
最后,VS2010的vb.net工程中引用这个dll,编写对远程oracle数据库的操作测试,通过!
写这么多只是因为忒郁闷!我喜欢开源MySQL、sqlite;还没有自己创业,给别人打工不自由啊,只能按照项目要求来。郁闷!!!
'引入oracle本身提供的.net数据引擎
Imports System
Imports System.Collections.Generic
Imports System.Text
Imports System.Data
Imports System.Xml
Imports System.Collections
Imports Oracle.DataAccess
Imports Oracle.DataAccess.Server
Imports Oracle.DataAccess.Client
Imports Oracle.DataAccess.Types
'引入开源日志类库
Imports log4net
Public Class OracleDbOperations
'定义日志对象 OracleHelper.Logging
'Private Shared Log As log4net.ILog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType)
Private Shared Log As log4net.ILog = log4net.LogManager.GetLogger("OracleHelper.Logging")
'数据库连接对象
Dim Conn As OracleConnection = Nothing
'事务处理对象
Dim Trans As OracleTransaction = Nothing
'数据库连接字符串
Dim ConnectionStr As String = Nothing
'构造函数
Sub New(ByVal ConnStr As String)
ConnectionStr = ConnStr
Conn = New OracleConnection(ConnectionStr)
End Sub
''' <summary>
''' 关闭数据库连接
''' </summary>
''' <returns>布尔值</returns>
''' <remarks>成功关闭返回true;否则返回false</remarks>
Public Function ConnClose() As Boolean
Try
If Conn.State <> ConnectionState.Closed Then
Conn.Close()
Conn.Dispose()
Conn = Nothing
Log.Info("数据库关闭连接成功!")
Return True
End If
Catch ex As Exception
'写日志
Log.Error("数据库关闭连接失败!")
End Try
Return False
End Function
''' <summary>
''' 打开数据库连接
''' </summary>
''' <returns>布尔值</returns>
''' <remarks>成功关闭返回true;否则返回false</remarks>
Public Function ConnOpen() As Boolean
Try
If Conn.State <> ConnectionState.Open Then
Conn.Open()
Log.Info("数据库打开连接成功!")
Return True
End If
Catch ex As Exception
'写日志
Log.Error("数据库打开连接失败!")
End Try
Return False
End Function
''' <summary>
''' 执行SQL语句或者存储过程(对于输入输出参数值为nothing的字段进行特殊处理为DBNull.Value);此为查询类型,不提供事务处理支持
''' </summary>
''' <param name="cmdType">执行类型</param>
''' <param name="cmdText">执行文本</param>
''' <param name="params">输入输出参数信息</param>
''' <returns>返回影响的行数</returns>
''' <remarks></remarks>
Public Function ExecuteNoneQuery(ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As Integer
Dim rows As Integer = 0
Try
If ConnOpen() Then
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
rows = cmd.ExecuteNonQuery()
'清理资源
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
'关闭连接
ConnClose()
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteNonQuery出现异常!")
End Try
Return rows
End Function
''' <summary>
''' 执行SQL语句或者存储过程(对于输入输出参数值为nothing的字段进行特殊处理为DBNull.Value);此为增删改,提供事务处理支持
''' </summary>
''' <param name="cmdType">执行类型</param>
''' <param name="cmdText">执行文本</param>
''' <param name="params">输入输出参数信息</param>
''' <returns>返回影响的行数</returns>
''' <remarks></remarks>
Public Function ExecuteNoneQueryTrans(ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As Integer
Dim rows As Integer = 0
Try
If ConnOpen() Then
Trans = Conn.BeginTransaction
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
rows = cmd.ExecuteNonQuery()
Trans.Commit()
'清理资源
Trans.Dispose()
Trans = Nothing
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
'关闭连接
ConnClose()
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteNonQuery出现异常!")
If IsNothing(Trans) = False Then
Trans.Rollback()
Trans.Dispose()
Trans = Nothing
End If
End Try
Return rows
End Function
''' <summary>
''' 返回记录集
''' </summary>
''' <param name="DsTable">记录集中表名</param>
''' <param name="cmdType">类型</param>
''' <param name="cmdText">文本</param>
''' <param name="params">输入输出参数</param>
''' <returns>返回dateset或者nothing</returns>
''' <remarks>必须首先判断返回值是否是nothing</remarks>
Public Function ExecuteDataSet(ByVal DsTable As String, ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As DataSet
Dim ds As DataSet = Nothing
Try
If ConnOpen() Then
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
Dim da As New OracleDataAdapter(cmd)
ds = New DataSet
da.Fill(ds, DsTable)
'清理资源
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
da.Dispose()
da = Nothing
'关闭连接
ConnClose()
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteDataSet出现异常!")
End Try
Return ds
End Function
''' <summary>
''' 返回XmlReader
''' </summary>
''' <param name="cmdType">类型</param>
''' <param name="cmdText">文本</param>
''' <param name="params">输入输出参数</param>
''' <returns>返回 或者nothing</returns>
''' <remarks>注意:调用该方法后,一定要对XmlReader进行Close</remarks>
Public Function ExecuteXmlReader(ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As XmlReader
Dim dr As XmlReader = Nothing
Try
If ConnOpen() Then
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
'执行
dr = cmd.ExecuteXmlReader
'清理资源
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteXmlReader出现异常!")
End Try
Return dr
End Function
''' <summary>
''' 执行SQL语句或者存储过程(对于输入输出参数值为nothing的字段进行特殊处理为DBNull.Value);此为查询类型,不提供事务处理支持
''' </summary>
''' <param name="cmdType">执行类型</param>
''' <param name="cmdText">执行文本</param>
''' <param name="params">输入输出参数信息</param>
''' <returns>返回一个object类型的结果</returns>
''' <remarks>对返回值进行ctype()类型装换后使用</remarks>
Public Function ExecuteScalar(ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As Object
Dim Result As Object = 0
Try
If ConnOpen() Then
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
Result = cmd.ExecuteScalar()
'清理资源
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
'关闭连接
ConnClose()
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteScalar出现异常!")
End Try
Return Result
End Function
''' <summary>
''' 返回datareader
''' </summary>
''' <param name="cmdType">类型</param>
''' <param name="cmdText">文本</param>
''' <param name="params">输入输出参数</param>
''' <returns>返回 或者nothing</returns>
''' <remarks>注意:调用该方法后,一定要对OracleDataReader进行Close</remarks>
Public Function ExecuteDataReader(ByVal cmdType As CommandType, ByVal cmdText As String, ByVal params As OracleParameter()) As OracleDataReader
Dim dr As OracleDataReader = Nothing
Try
If ConnOpen() Then
Dim cmd As New OracleCommand
cmd.Connection = Conn
cmd.CommandType = cmdType
cmd.CommandText = cmdText
'有参数时
If params IsNot Nothing AndAlso params.Length > 0 Then
For Each p As OracleParameter In params
'对NULL值的参数数据进行特殊处理(VB中对NULL赋值为Nohting)
If p.Direction = ParameterDirection.InputOutput AndAlso p.Value Is Nothing Then
p.Value = DBNull.Value
End If
cmd.Parameters.Add(p)
Next
End If
'执行
dr = cmd.ExecuteReader(CommandBehavior.CloseConnection)
'清理资源
cmd.Parameters.Clear()
cmd.Dispose()
cmd = Nothing
Else
'写日志
Log.Error("数据库打开连接失败!")
End If
Catch ex As Exception
'写日志
Log.Error("<" & cmdText & ">执行ExecuteDataReader出现异常!")
End Try
Return dr
End Function
欢迎光临 信息发布软件,b2b软件,广告发布软件 (http://postbbs.com/) | Powered by Discuz! X3.2 |