1 Star 0 Fork 0

dcharles / fabric-ca

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
sqlxTx.go 13.76 KB
一键复制 编辑 原始数据 按行查看 历史
Saad Karim 提交于 2019-01-07 14:02 . [FABC-803] Refactoring DB code
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554
// Code generated by counterfeiter. DO NOT EDIT.
package mocks
import (
sql "database/sql"
sync "sync"
db "github.com/hyperledger/fabric-ca/lib/server/db"
sqlx "github.com/jmoiron/sqlx"
)
type SqlxTx struct {
CommitStub func() error
commitMutex sync.RWMutex
commitArgsForCall []struct {
}
commitReturns struct {
result1 error
}
commitReturnsOnCall map[int]struct {
result1 error
}
ExecStub func(string, ...interface{}) (sql.Result, error)
execMutex sync.RWMutex
execArgsForCall []struct {
arg1 string
arg2 []interface{}
}
execReturns struct {
result1 sql.Result
result2 error
}
execReturnsOnCall map[int]struct {
result1 sql.Result
result2 error
}
GetStub func(interface{}, string, ...interface{}) error
getMutex sync.RWMutex
getArgsForCall []struct {
arg1 interface{}
arg2 string
arg3 []interface{}
}
getReturns struct {
result1 error
}
getReturnsOnCall map[int]struct {
result1 error
}
QueryxStub func(string, ...interface{}) (*sqlx.Rows, error)
queryxMutex sync.RWMutex
queryxArgsForCall []struct {
arg1 string
arg2 []interface{}
}
queryxReturns struct {
result1 *sqlx.Rows
result2 error
}
queryxReturnsOnCall map[int]struct {
result1 *sqlx.Rows
result2 error
}
RebindStub func(string) string
rebindMutex sync.RWMutex
rebindArgsForCall []struct {
arg1 string
}
rebindReturns struct {
result1 string
}
rebindReturnsOnCall map[int]struct {
result1 string
}
RollbackStub func() error
rollbackMutex sync.RWMutex
rollbackArgsForCall []struct {
}
rollbackReturns struct {
result1 error
}
rollbackReturnsOnCall map[int]struct {
result1 error
}
SelectStub func(interface{}, string, ...interface{}) error
selectMutex sync.RWMutex
selectArgsForCall []struct {
arg1 interface{}
arg2 string
arg3 []interface{}
}
selectReturns struct {
result1 error
}
selectReturnsOnCall map[int]struct {
result1 error
}
invocations map[string][][]interface{}
invocationsMutex sync.RWMutex
}
func (fake *SqlxTx) Commit() error {
fake.commitMutex.Lock()
ret, specificReturn := fake.commitReturnsOnCall[len(fake.commitArgsForCall)]
fake.commitArgsForCall = append(fake.commitArgsForCall, struct {
}{})
fake.recordInvocation("Commit", []interface{}{})
fake.commitMutex.Unlock()
if fake.CommitStub != nil {
return fake.CommitStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.commitReturns
return fakeReturns.result1
}
func (fake *SqlxTx) CommitCallCount() int {
fake.commitMutex.RLock()
defer fake.commitMutex.RUnlock()
return len(fake.commitArgsForCall)
}
func (fake *SqlxTx) CommitCalls(stub func() error) {
fake.commitMutex.Lock()
defer fake.commitMutex.Unlock()
fake.CommitStub = stub
}
func (fake *SqlxTx) CommitReturns(result1 error) {
fake.commitMutex.Lock()
defer fake.commitMutex.Unlock()
fake.CommitStub = nil
fake.commitReturns = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) CommitReturnsOnCall(i int, result1 error) {
fake.commitMutex.Lock()
defer fake.commitMutex.Unlock()
fake.CommitStub = nil
if fake.commitReturnsOnCall == nil {
fake.commitReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.commitReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) Exec(arg1 string, arg2 ...interface{}) (sql.Result, error) {
fake.execMutex.Lock()
ret, specificReturn := fake.execReturnsOnCall[len(fake.execArgsForCall)]
fake.execArgsForCall = append(fake.execArgsForCall, struct {
arg1 string
arg2 []interface{}
}{arg1, arg2})
fake.recordInvocation("Exec", []interface{}{arg1, arg2})
fake.execMutex.Unlock()
if fake.ExecStub != nil {
return fake.ExecStub(arg1, arg2...)
}
if specificReturn {
return ret.result1, ret.result2
}
fakeReturns := fake.execReturns
return fakeReturns.result1, fakeReturns.result2
}
func (fake *SqlxTx) ExecCallCount() int {
fake.execMutex.RLock()
defer fake.execMutex.RUnlock()
return len(fake.execArgsForCall)
}
func (fake *SqlxTx) ExecCalls(stub func(string, ...interface{}) (sql.Result, error)) {
fake.execMutex.Lock()
defer fake.execMutex.Unlock()
fake.ExecStub = stub
}
func (fake *SqlxTx) ExecArgsForCall(i int) (string, []interface{}) {
fake.execMutex.RLock()
defer fake.execMutex.RUnlock()
argsForCall := fake.execArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *SqlxTx) ExecReturns(result1 sql.Result, result2 error) {
fake.execMutex.Lock()
defer fake.execMutex.Unlock()
fake.ExecStub = nil
fake.execReturns = struct {
result1 sql.Result
result2 error
}{result1, result2}
}
func (fake *SqlxTx) ExecReturnsOnCall(i int, result1 sql.Result, result2 error) {
fake.execMutex.Lock()
defer fake.execMutex.Unlock()
fake.ExecStub = nil
if fake.execReturnsOnCall == nil {
fake.execReturnsOnCall = make(map[int]struct {
result1 sql.Result
result2 error
})
}
fake.execReturnsOnCall[i] = struct {
result1 sql.Result
result2 error
}{result1, result2}
}
func (fake *SqlxTx) Get(arg1 interface{}, arg2 string, arg3 ...interface{}) error {
fake.getMutex.Lock()
ret, specificReturn := fake.getReturnsOnCall[len(fake.getArgsForCall)]
fake.getArgsForCall = append(fake.getArgsForCall, struct {
arg1 interface{}
arg2 string
arg3 []interface{}
}{arg1, arg2, arg3})
fake.recordInvocation("Get", []interface{}{arg1, arg2, arg3})
fake.getMutex.Unlock()
if fake.GetStub != nil {
return fake.GetStub(arg1, arg2, arg3...)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.getReturns
return fakeReturns.result1
}
func (fake *SqlxTx) GetCallCount() int {
fake.getMutex.RLock()
defer fake.getMutex.RUnlock()
return len(fake.getArgsForCall)
}
func (fake *SqlxTx) GetCalls(stub func(interface{}, string, ...interface{}) error) {
fake.getMutex.Lock()
defer fake.getMutex.Unlock()
fake.GetStub = stub
}
func (fake *SqlxTx) GetArgsForCall(i int) (interface{}, string, []interface{}) {
fake.getMutex.RLock()
defer fake.getMutex.RUnlock()
argsForCall := fake.getArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
}
func (fake *SqlxTx) GetReturns(result1 error) {
fake.getMutex.Lock()
defer fake.getMutex.Unlock()
fake.GetStub = nil
fake.getReturns = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) GetReturnsOnCall(i int, result1 error) {
fake.getMutex.Lock()
defer fake.getMutex.Unlock()
fake.GetStub = nil
if fake.getReturnsOnCall == nil {
fake.getReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.getReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) Queryx(arg1 string, arg2 ...interface{}) (*sqlx.Rows, error) {
fake.queryxMutex.Lock()
ret, specificReturn := fake.queryxReturnsOnCall[len(fake.queryxArgsForCall)]
fake.queryxArgsForCall = append(fake.queryxArgsForCall, struct {
arg1 string
arg2 []interface{}
}{arg1, arg2})
fake.recordInvocation("Queryx", []interface{}{arg1, arg2})
fake.queryxMutex.Unlock()
if fake.QueryxStub != nil {
return fake.QueryxStub(arg1, arg2...)
}
if specificReturn {
return ret.result1, ret.result2
}
fakeReturns := fake.queryxReturns
return fakeReturns.result1, fakeReturns.result2
}
func (fake *SqlxTx) QueryxCallCount() int {
fake.queryxMutex.RLock()
defer fake.queryxMutex.RUnlock()
return len(fake.queryxArgsForCall)
}
func (fake *SqlxTx) QueryxCalls(stub func(string, ...interface{}) (*sqlx.Rows, error)) {
fake.queryxMutex.Lock()
defer fake.queryxMutex.Unlock()
fake.QueryxStub = stub
}
func (fake *SqlxTx) QueryxArgsForCall(i int) (string, []interface{}) {
fake.queryxMutex.RLock()
defer fake.queryxMutex.RUnlock()
argsForCall := fake.queryxArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2
}
func (fake *SqlxTx) QueryxReturns(result1 *sqlx.Rows, result2 error) {
fake.queryxMutex.Lock()
defer fake.queryxMutex.Unlock()
fake.QueryxStub = nil
fake.queryxReturns = struct {
result1 *sqlx.Rows
result2 error
}{result1, result2}
}
func (fake *SqlxTx) QueryxReturnsOnCall(i int, result1 *sqlx.Rows, result2 error) {
fake.queryxMutex.Lock()
defer fake.queryxMutex.Unlock()
fake.QueryxStub = nil
if fake.queryxReturnsOnCall == nil {
fake.queryxReturnsOnCall = make(map[int]struct {
result1 *sqlx.Rows
result2 error
})
}
fake.queryxReturnsOnCall[i] = struct {
result1 *sqlx.Rows
result2 error
}{result1, result2}
}
func (fake *SqlxTx) Rebind(arg1 string) string {
fake.rebindMutex.Lock()
ret, specificReturn := fake.rebindReturnsOnCall[len(fake.rebindArgsForCall)]
fake.rebindArgsForCall = append(fake.rebindArgsForCall, struct {
arg1 string
}{arg1})
fake.recordInvocation("Rebind", []interface{}{arg1})
fake.rebindMutex.Unlock()
if fake.RebindStub != nil {
return fake.RebindStub(arg1)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.rebindReturns
return fakeReturns.result1
}
func (fake *SqlxTx) RebindCallCount() int {
fake.rebindMutex.RLock()
defer fake.rebindMutex.RUnlock()
return len(fake.rebindArgsForCall)
}
func (fake *SqlxTx) RebindCalls(stub func(string) string) {
fake.rebindMutex.Lock()
defer fake.rebindMutex.Unlock()
fake.RebindStub = stub
}
func (fake *SqlxTx) RebindArgsForCall(i int) string {
fake.rebindMutex.RLock()
defer fake.rebindMutex.RUnlock()
argsForCall := fake.rebindArgsForCall[i]
return argsForCall.arg1
}
func (fake *SqlxTx) RebindReturns(result1 string) {
fake.rebindMutex.Lock()
defer fake.rebindMutex.Unlock()
fake.RebindStub = nil
fake.rebindReturns = struct {
result1 string
}{result1}
}
func (fake *SqlxTx) RebindReturnsOnCall(i int, result1 string) {
fake.rebindMutex.Lock()
defer fake.rebindMutex.Unlock()
fake.RebindStub = nil
if fake.rebindReturnsOnCall == nil {
fake.rebindReturnsOnCall = make(map[int]struct {
result1 string
})
}
fake.rebindReturnsOnCall[i] = struct {
result1 string
}{result1}
}
func (fake *SqlxTx) Rollback() error {
fake.rollbackMutex.Lock()
ret, specificReturn := fake.rollbackReturnsOnCall[len(fake.rollbackArgsForCall)]
fake.rollbackArgsForCall = append(fake.rollbackArgsForCall, struct {
}{})
fake.recordInvocation("Rollback", []interface{}{})
fake.rollbackMutex.Unlock()
if fake.RollbackStub != nil {
return fake.RollbackStub()
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.rollbackReturns
return fakeReturns.result1
}
func (fake *SqlxTx) RollbackCallCount() int {
fake.rollbackMutex.RLock()
defer fake.rollbackMutex.RUnlock()
return len(fake.rollbackArgsForCall)
}
func (fake *SqlxTx) RollbackCalls(stub func() error) {
fake.rollbackMutex.Lock()
defer fake.rollbackMutex.Unlock()
fake.RollbackStub = stub
}
func (fake *SqlxTx) RollbackReturns(result1 error) {
fake.rollbackMutex.Lock()
defer fake.rollbackMutex.Unlock()
fake.RollbackStub = nil
fake.rollbackReturns = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) RollbackReturnsOnCall(i int, result1 error) {
fake.rollbackMutex.Lock()
defer fake.rollbackMutex.Unlock()
fake.RollbackStub = nil
if fake.rollbackReturnsOnCall == nil {
fake.rollbackReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.rollbackReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) Select(arg1 interface{}, arg2 string, arg3 ...interface{}) error {
fake.selectMutex.Lock()
ret, specificReturn := fake.selectReturnsOnCall[len(fake.selectArgsForCall)]
fake.selectArgsForCall = append(fake.selectArgsForCall, struct {
arg1 interface{}
arg2 string
arg3 []interface{}
}{arg1, arg2, arg3})
fake.recordInvocation("Select", []interface{}{arg1, arg2, arg3})
fake.selectMutex.Unlock()
if fake.SelectStub != nil {
return fake.SelectStub(arg1, arg2, arg3...)
}
if specificReturn {
return ret.result1
}
fakeReturns := fake.selectReturns
return fakeReturns.result1
}
func (fake *SqlxTx) SelectCallCount() int {
fake.selectMutex.RLock()
defer fake.selectMutex.RUnlock()
return len(fake.selectArgsForCall)
}
func (fake *SqlxTx) SelectCalls(stub func(interface{}, string, ...interface{}) error) {
fake.selectMutex.Lock()
defer fake.selectMutex.Unlock()
fake.SelectStub = stub
}
func (fake *SqlxTx) SelectArgsForCall(i int) (interface{}, string, []interface{}) {
fake.selectMutex.RLock()
defer fake.selectMutex.RUnlock()
argsForCall := fake.selectArgsForCall[i]
return argsForCall.arg1, argsForCall.arg2, argsForCall.arg3
}
func (fake *SqlxTx) SelectReturns(result1 error) {
fake.selectMutex.Lock()
defer fake.selectMutex.Unlock()
fake.SelectStub = nil
fake.selectReturns = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) SelectReturnsOnCall(i int, result1 error) {
fake.selectMutex.Lock()
defer fake.selectMutex.Unlock()
fake.SelectStub = nil
if fake.selectReturnsOnCall == nil {
fake.selectReturnsOnCall = make(map[int]struct {
result1 error
})
}
fake.selectReturnsOnCall[i] = struct {
result1 error
}{result1}
}
func (fake *SqlxTx) Invocations() map[string][][]interface{} {
fake.invocationsMutex.RLock()
defer fake.invocationsMutex.RUnlock()
fake.commitMutex.RLock()
defer fake.commitMutex.RUnlock()
fake.execMutex.RLock()
defer fake.execMutex.RUnlock()
fake.getMutex.RLock()
defer fake.getMutex.RUnlock()
fake.queryxMutex.RLock()
defer fake.queryxMutex.RUnlock()
fake.rebindMutex.RLock()
defer fake.rebindMutex.RUnlock()
fake.rollbackMutex.RLock()
defer fake.rollbackMutex.RUnlock()
fake.selectMutex.RLock()
defer fake.selectMutex.RUnlock()
copiedInvocations := map[string][][]interface{}{}
for key, value := range fake.invocations {
copiedInvocations[key] = value
}
return copiedInvocations
}
func (fake *SqlxTx) recordInvocation(key string, args []interface{}) {
fake.invocationsMutex.Lock()
defer fake.invocationsMutex.Unlock()
if fake.invocations == nil {
fake.invocations = map[string][][]interface{}{}
}
if fake.invocations[key] == nil {
fake.invocations[key] = [][]interface{}{}
}
fake.invocations[key] = append(fake.invocations[key], args)
}
var _ db.SqlxTx = new(SqlxTx)
1
https://gitee.com/dcharles/fabric-ca-official.git
git@gitee.com:dcharles/fabric-ca-official.git
dcharles
fabric-ca-official
fabric-ca
v1.4.7

搜索帮助

53164aa7 5694891 3bd8fe86 5694891