libraries/doltcore/sqle/dfunctions: fix dropped errrors

This commit is contained in:
Lars Lehtonen
2021-03-08 17:23:34 -08:00
parent 9ef07e769e
commit 82e7d3d4f5
5 changed files with 30 additions and 17 deletions
@@ -44,6 +44,9 @@ func (cf *CommitFunc) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) {
// Get the params associated with COMMIT.
ap := cli.CreateCommitArgParser()
args, err := getDoltArgs(ctx, row, cf.Children())
if err != nil {
return nil, err
}
apr := cli.ParseArgs(ap, args, nil)
var name, email string
@@ -129,6 +129,9 @@ func (d DoltCommitFunc) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)
Name: name,
Email: email,
})
if err != nil {
return nil, err
}
if allFlag {
err = setHeadAndWorkingSessionRoot(ctx, h)
@@ -62,7 +62,6 @@ func (d DoltResetFunc) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)
// Get all the needed roots.
working, staged, head, err := env.GetRoots(ctx, dbData.Ddb, dbData.Rsr)
if err != nil {
return 1, err
}
@@ -81,22 +80,24 @@ func (d DoltResetFunc) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)
}
h = headHash.String()
err = setSessionRootExplicit(ctx, h, sqle.HeadKeySuffix)
if err != nil {
if err := setSessionRootExplicit(ctx, h, sqle.HeadKeySuffix); err != nil {
return 1, err
}
workingHash := dbData.Rsr.WorkingHash()
err = setSessionRootExplicit(ctx, workingHash.String(), sqle.WorkingKeySuffix)
if err := setSessionRootExplicit(ctx, workingHash.String(), sqle.WorkingKeySuffix); err != nil {
return 1, err
}
} else {
err = setHeadAndWorkingSessionRoot(ctx, h)
if err := setHeadAndWorkingSessionRoot(ctx, h); err != nil {
return 1, err
}
}
} else {
_, err = actions.ResetSoftTables(ctx, dbData, apr, staged, head)
}
if err != nil {
return 1, err
if err != nil {
return 1, err
}
}
return 0, nil
@@ -58,7 +58,6 @@ func (t *HashOf) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) {
}
name, as, err := doltdb.SplitAncestorSpec(paramStr)
if err != nil {
return nil, err
}
@@ -74,28 +73,27 @@ func (t *HashOf) Eval(ctx *sql.Context, row sql.Row) (interface{}, error) {
sess := sqle.DSessFromSess(ctx.Session)
cm, _, err = sess.GetParentCommit(ctx, dbName)
if err != nil {
return nil, err
}
} else {
branchRef, err := getBranchInsensitive(ctx, name, ddb)
if err != nil {
return nil, err
}
cm, err = ddb.ResolveRef(ctx, branchRef)
}
if err != nil {
return nil, err
if err != nil {
return nil, err
}
}
cm, err = cm.GetAncestor(ctx, as)
if err != nil {
return nil, err
}
h, err := cm.HashOf()
if err != nil {
return nil, err
}
@@ -154,6 +154,10 @@ func checkForUncommittedChanges(root *doltdb.RootValue, parentRoot *doltdb.RootV
}
func getBranchCommit(ctx *sql.Context, ok bool, val interface{}, err error, ddb *doltdb.DoltDB) (*doltdb.Commit, hash.Hash, error) {
if err != nil {
return nil, hash.Hash{}, err
}
paramStr, ok := val.(string)
if !ok {
@@ -182,6 +186,10 @@ func getBranchCommit(ctx *sql.Context, ok bool, val interface{}, err error, ddb
}
func getParent(ctx *sql.Context, err error, sess *sqle.DoltSession, dbName string) (*doltdb.Commit, hash.Hash, *doltdb.RootValue, error) {
if err != nil {
return nil, hash.Hash{}, nil, err
}
parent, ph, err := sess.GetParentCommit(ctx, dbName)
if err != nil {