Golang gomdb.Txn类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/jbooth/gomdb.Txn类的典型用法代码示例。如果您正苦于以下问题：Golang Txn类的具体用法？Golang Txn怎么用？Golang Txn使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Txn类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: CloseTransaction

// aborts transactionsuppressing any errors, and frees
func (e *env) CloseTransaction(t *mdb.Txn) error {
	t.Abort() // ignore error
	e.l.Lock()
	defer e.l.Unlock()
	e.numOpen--
	if e.shouldClose && e.numOpen == 0 && !e.closed {
		e.e.Close()
		e.closed = true
	}
	e.e.Close()
	return nil
}

开发者ID:jbooth，项目名称:flotilla，代码行数:13，代码来源:env.go

示例2: remove

// remove
// arg0: dbName
// arg1: key
// returns nil
func remove(args [][]byte, txn *mdb.Txn) ([]byte, error) {
	dbName := string(args[0])
	dbi, err := txn.DBIOpen(&dbName, mdb.CREATE) // create if not exists
	if err != nil {
		txn.Abort()
		return nil, err
	}
	err = txn.Del(dbi, args[1], nil)
	if err != nil {
		txn.Abort()
		return nil, err
	}
	return nil, txn.Commit()
}

开发者ID:jbooth，项目名称:flotilla，代码行数:18，代码来源:lib.go

示例3: get

// transactional get for testing get commands over the wire
// arg0: dbName
// arg1: key
func get(args [][]byte, txn *mdb.Txn) ([]byte, error) {
	if len(args) < 2 {
		return nil, fmt.Errorf("Get needs 2 arguments!  Got %d args", len(args))
	}
	dbName := string(args[0])
	dbi, err := txn.DBIOpen(&dbName, mdb.CREATE) // create if not exists
	if err != nil {
		txn.Abort()
		return nil, err
	}
	ret, err := txn.Get(dbi, args[1])
	if err != nil {
		txn.Abort()
		return nil, err
	}
	txn.Abort()
	return ret, err
}

开发者ID:jbooth，项目名称:flotilla，代码行数:21，代码来源:server_test.go

示例4: put

// put
// arg0: dbName
// arg1: key
// arg2: value
// returns nil
func put(args [][]byte, txn *mdb.Txn) ([]byte, error) {
	if len(args) < 3 {
		return nil, fmt.Errorf("Put needs 3 arguments!  Got %d args", len(args))
	}
	dbName := string(args[0])
	dbi, err := txn.DBIOpen(&dbName, mdb.CREATE) // create if not exists
	if err != nil {
		txn.Abort()
		return nil, err
	}
	err = txn.Put(dbi, args[1], args[2], 0)
	if err != nil {
		txn.Abort()
		return nil, err
	}
	err = txn.Commit()
	return nil, err
}

开发者ID:jbooth，项目名称:flotilla，代码行数:23，代码来源:lib.go

示例5: putIfAbsent

// put if not already set
// arg0:  dbName
// arg1:  key
// arg2:  value
// return:  [1] if added, [0] otherwise
func putIfAbsent(args [][]byte, txn *mdb.Txn) ([]byte, error) {
	dbName := string(args[0])
	dbi, err := txn.DBIOpen(&dbName, mdb.CREATE) // create if not exists
	if err != nil {
		txn.Abort()
		return nil, err
	}
	err = txn.Put(dbi, args[1], args[2], mdb.NOOVERWRITE)
	if err == mdb.KeyExist {
		txn.Abort()
		return []byte{0}, nil
	}
	if err != nil {
		txn.Abort()
		return nil, err
	}
	err = txn.Commit()
	return []byte{1}, err
}

开发者ID:jbooth，项目名称:flotilla，代码行数:24，代码来源:lib.go

示例6: compareAndRemove

// remove if set to expected val
// arg0: dbName
// arg1: key
// arg2: expectedVal
// ret:  [1] if removed, [0] otherwise
func compareAndRemove(args [][]byte, txn *mdb.Txn) ([]byte, error) {
	dbName := string(args[0])
	dbi, err := txn.DBIOpen(&dbName, mdb.CREATE) // create if not exists
	existingVal, err := txn.Get(dbi, args[1])
	if err != nil && err != mdb.NotFound {
		txn.Abort()
		return nil, err
	}
	if err == mdb.NotFound || bytesEqual(args[2], existingVal) {
		err = txn.Del(dbi, args[1], nil)
		if err != nil {
			return nil, err
		}
		err = txn.Commit()
		return args[3], err
	} else {
		txn.Abort()
		return existingVal, nil
	}
}

开发者ID:jbooth，项目名称:flotilla，代码行数:25，代码来源:lib.go

注：本文中的github.com/jbooth/gomdb.Txn类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。