noth/surrealpatch
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Don’t ignore transaction errors

Browse source
This commit is contained in:
Tobie Morgan Hitchcock 2019-12-02 23:29:18 +00:00
parent 70026fe8d7
commit 63cbb59bae
3 changed files with 15 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
txn/db.go
View file

@ -84,7 +84,11 @@ func (t *TX) AddDB(ctx context.Context, ns, db string) (val *sql.DefineDatabaseS
key := &keys.DB{KV: cnf.Settings.DB.Base, NS: ns, DB: db}
if kv, _ = t.Get(ctx, 0, key.Encode()); kv.Exi() {
if kv, err = t.Get(ctx, 0, key.Encode()); err != nil {
return
}
if kv != nil && kv.Exi() {
val = &sql.DefineDatabaseStatement{}
val.Decode(kv.Val())
t.set(_db, db, val)

6
txn/ns.go
View file

@ -80,7 +80,11 @@ func (t *TX) AddNS(ctx context.Context, ns string) (val *sql.DefineNamespaceStat
key := &keys.NS{KV: cnf.Settings.DB.Base, NS: ns}
if kv, _ = t.Get(ctx, 0, key.Encode()); kv.Exi() {
if kv, err = t.Get(ctx, 0, key.Encode()); err != nil {
return
}
if kv != nil && kv.Exi() {
val = &sql.DefineNamespaceStatement{}
val.Decode(kv.Val())
t.set(_ns, ns, val)

6
txn/tb.go
View file

@ -84,7 +84,11 @@ func (t *TX) AddTB(ctx context.Context, ns, db, tb string) (val *sql.DefineTable
key := &keys.TB{KV: cnf.Settings.DB.Base, NS: ns, DB: db, TB: tb}
if kv, _ = t.Get(ctx, 0, key.Encode()); kv.Exi() {
if kv, err = t.Get(ctx, 0, key.Encode()); err != nil {
return
}
if kv != nil && kv.Exi() {
val = &sql.DefineTableStatement{}
val.Decode(kv.Val())
t.set(_tb, tb, val)