信息发布软件,b2b软件,广告发布软件

标题: VB.NET使用数据库事务如何灵活我用就得靠这个OracleTransaction [打印本页]

作者: 群发软件    时间: 2017-5-25 23:56
标题: VB.NET使用数据库事务如何灵活我用就得靠这个OracleTransaction
本帖最后由 群发软件 于 2017-5-25 23:58 编辑

数据库事务简介

  数据库事务是由一组 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

开始事务:



[c-sharp] view plain copy




提交:


[c-sharp] view plain copy




回滚:


[c-sharp] view plain copy





在事件内进行SQL语句相关执行:


[c-sharp] view plain copy





要注意的是,在事务进行中,不能再对同一个数据库连接(OracleConnection)再进行事务外的数据的查询和读取,也就是说,类似下边的语句是不能执行的:


[c-sharp] view plain copy




而是得加一条语句,在事务内进行查询:


[c-sharp] view plain copy






BTW:  转载一些资料:



[c-sharp] view plain copy




特郁闷的一件事情,费时费力!记下来,为后来者铺路。

首先,我用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


作者: q1598188    时间: 2017-5-26 14:40
非常周到耐心,满意好评
作者: z2340868    时间: 2017-5-27 15:23
网站制作的很好,企业团队效率就是高!
作者: cjagl520    时间: 2017-5-30 02:32
真是收益匪浅
作者: shenyeben    时间: 2017-5-31 14:41
,很高端的视觉效应,很耐心,设计的很不错,高端大气上档次啊!技术人员很给力,专业的就是专业的,为卖家耐心热情的服务态度点个赞!下次有需要还会来!~
作者: tian001    时间: 2017-6-4 17:10
真好,很有耐心,慢慢就熟悉了!很好!还会再来的
作者: yerface    时间: 2017-6-11 13:29
我家设计的图纸太漂亮了,以前只是听说,没用过,现在看到了确实不错,我们都很满意。值得推广,真心感谢客服态度超好,非常有默契,不用多说就知道怎样装修,给32个赞
作者: ctbvip    时间: 2017-6-11 16:58
值得好评,赞一个!!!
作者: 261741908    时间: 2017-6-12 15:10
很快效果也很完美,特别感谢技术加班帮忙制作!@!@~~客服沟通也很愉快,好多不明白的地方客服也都耐心解答,辛苦啦
作者: 261741908    时间: 2017-6-22 19:59
感谢店家的细心指导!!好评!
作者: 阿拉丁    时间: 2017-6-23 00:11
好,页面设计很满意,而且也很快,非常有效率,第一次买,遇到这么好的卖家,这么高效的服务,真的太幸运了,太谢




欢迎光临 信息发布软件,b2b软件,广告发布软件 (http://www.postbbs.com/) Powered by Discuz! X3.2