aboutsummaryrefslogtreecommitdiff
path: root/vendor/github.com/denisenkom/go-mssqldb/tran.go
diff options
context:
space:
mode:
authorUnknwon <u@gogs.io>2019-10-23 23:03:17 -0700
committerGitHub <noreply@github.com>2019-10-23 23:03:17 -0700
commit613139e7bef81d3573e7988a47eb6765f3de347a (patch)
tree49de7277898d3ff47a122c072568edb8ed4c9ac9 /vendor/github.com/denisenkom/go-mssqldb/tran.go
parentfb100dbf98f02e4c631d142ff0f52ec29ee2f00c (diff)
Enable Go modules (#5835)
* Remove vendor * Enable Go modules * ci: add command to fetch dependencies * ci: update setting * ci: update settings * Require Go 1.11 * Rename module name to gogs.io/gogs
Diffstat (limited to 'vendor/github.com/denisenkom/go-mssqldb/tran.go')
-rw-r--r--vendor/github.com/denisenkom/go-mssqldb/tran.go111
1 files changed, 0 insertions, 111 deletions
diff --git a/vendor/github.com/denisenkom/go-mssqldb/tran.go b/vendor/github.com/denisenkom/go-mssqldb/tran.go
deleted file mode 100644
index 75e7a2ae..00000000
--- a/vendor/github.com/denisenkom/go-mssqldb/tran.go
+++ /dev/null
@@ -1,111 +0,0 @@
-package mssql
-
-// Transaction Manager requests
-// http://msdn.microsoft.com/en-us/library/dd339887.aspx
-
-import (
- "encoding/binary"
-)
-
-const (
- tmGetDtcAddr = 0
- tmPropagateXact = 1
- tmBeginXact = 5
- tmPromoteXact = 6
- tmCommitXact = 7
- tmRollbackXact = 8
- tmSaveXact = 9
-)
-
-type isoLevel uint8
-
-const (
- isolationUseCurrent isoLevel = 0
- isolationReadUncommited = 1
- isolationReadCommited = 2
- isolationRepeatableRead = 3
- isolationSerializable = 4
- isolationSnapshot = 5
-)
-
-func sendBeginXact(buf *tdsBuffer, headers []headerStruct, isolation isoLevel,
- name string) (err error) {
- buf.BeginPacket(packTransMgrReq)
- writeAllHeaders(buf, headers)
- var rqtype uint16 = tmBeginXact
- err = binary.Write(buf, binary.LittleEndian, &rqtype)
- if err != nil {
- return
- }
- err = binary.Write(buf, binary.LittleEndian, &isolation)
- if err != nil {
- return
- }
- err = writeBVarChar(buf, name)
- if err != nil {
- return
- }
- return buf.FinishPacket()
-}
-
-const (
- fBeginXact = 1
-)
-
-func sendCommitXact(buf *tdsBuffer, headers []headerStruct, name string, flags uint8, isolation uint8, newname string) error {
- buf.BeginPacket(packTransMgrReq)
- writeAllHeaders(buf, headers)
- var rqtype uint16 = tmCommitXact
- err := binary.Write(buf, binary.LittleEndian, &rqtype)
- if err != nil {
- return err
- }
- err = writeBVarChar(buf, name)
- if err != nil {
- return err
- }
- err = binary.Write(buf, binary.LittleEndian, &flags)
- if err != nil {
- return err
- }
- if flags&fBeginXact != 0 {
- err = binary.Write(buf, binary.LittleEndian, &isolation)
- if err != nil {
- return err
- }
- err = writeBVarChar(buf, name)
- if err != nil {
- return err
- }
- }
- return buf.FinishPacket()
-}
-
-func sendRollbackXact(buf *tdsBuffer, headers []headerStruct, name string, flags uint8, isolation uint8, newname string) error {
- buf.BeginPacket(packTransMgrReq)
- writeAllHeaders(buf, headers)
- var rqtype uint16 = tmRollbackXact
- err := binary.Write(buf, binary.LittleEndian, &rqtype)
- if err != nil {
- return err
- }
- err = writeBVarChar(buf, name)
- if err != nil {
- return err
- }
- err = binary.Write(buf, binary.LittleEndian, &flags)
- if err != nil {
- return err
- }
- if flags&fBeginXact != 0 {
- err = binary.Write(buf, binary.LittleEndian, &isolation)
- if err != nil {
- return err
- }
- err = writeBVarChar(buf, name)
- if err != nil {
- return err
- }
- }
- return buf.FinishPacket()
-}