@@ -437,20 +437,20 @@ func convertUpdate(ctx *sql.Context, d *sqlparser.Update) (sql.Node, error) {
437
437
return nil , err
438
438
}
439
439
440
- updateExprs , err := updateExprsToExpressions (d .Exprs )
440
+ updateExprs , err := updateExprsToExpressions (ctx , d .Exprs )
441
441
if err != nil {
442
442
return nil , err
443
443
}
444
444
445
445
if d .Where != nil {
446
- node , err = whereToFilter (d .Where , node )
446
+ node , err = whereToFilter (ctx , d .Where , node )
447
447
if err != nil {
448
448
return nil , err
449
449
}
450
450
}
451
451
452
452
if len (d .OrderBy ) != 0 {
453
- node , err = orderByToSort (d .OrderBy , node )
453
+ node , err = orderByToSort (ctx , d .OrderBy , node )
454
454
if err != nil {
455
455
return nil , err
456
456
}
@@ -1286,14 +1286,14 @@ func intervalExprToExpression(ctx *sql.Context, e *sqlparser.IntervalExpr) (sql.
1286
1286
return expression .NewInterval (expr , e .Unit ), nil
1287
1287
}
1288
1288
1289
- func updateExprsToExpressions (e sqlparser.UpdateExprs ) ([]sql.Expression , error ) {
1289
+ func updateExprsToExpressions (ctx * sql. Context , e sqlparser.UpdateExprs ) ([]sql.Expression , error ) {
1290
1290
res := make ([]sql.Expression , len (e ))
1291
1291
for i , updateExpr := range e {
1292
- colName , err := exprToExpression (updateExpr .Name )
1292
+ colName , err := exprToExpression (ctx , updateExpr .Name )
1293
1293
if err != nil {
1294
1294
return nil , err
1295
1295
}
1296
- innerExpr , err := exprToExpression (updateExpr .Expr )
1296
+ innerExpr , err := exprToExpression (ctx , updateExpr .Expr )
1297
1297
if err != nil {
1298
1298
return nil , err
1299
1299
}
0 commit comments