1
2
3
4
5
6
7 package sql
8
9 import (
10 "bytes"
11 "database/sql/driver"
12 "database/sql/internal"
13 "errors"
14 "fmt"
15 "reflect"
16 "strconv"
17 "time"
18 "unicode"
19 "unicode/utf8"
20 _ "unsafe"
21 "uuid"
22 )
23
24 var errNilPtr = errors.New("destination pointer is nil")
25
26 func describeNamedValue(nv *driver.NamedValue) string {
27 if len(nv.Name) == 0 {
28 return fmt.Sprintf("$%d", nv.Ordinal)
29 }
30 return fmt.Sprintf("with name %q", nv.Name)
31 }
32
33 func validateNamedValueName(name string) error {
34 if len(name) == 0 {
35 return nil
36 }
37 r, _ := utf8.DecodeRuneInString(name)
38 if unicode.IsLetter(r) {
39 return nil
40 }
41 return fmt.Errorf("name %q does not begin with a letter", name)
42 }
43
44
45
46
47 type ccChecker struct {
48 cci driver.ColumnConverter
49 want int
50 }
51
52 func (c ccChecker) CheckNamedValue(nv *driver.NamedValue) error {
53 if c.cci == nil {
54 return driver.ErrSkip
55 }
56
57
58
59 index := nv.Ordinal - 1
60 if c.want >= 0 && c.want <= index {
61 return nil
62 }
63
64
65
66
67 if vr, ok := nv.Value.(driver.Valuer); ok {
68 sv, err := callValuerValue(vr)
69 if err != nil {
70 return err
71 }
72 if !driver.IsValue(sv) {
73 return fmt.Errorf("non-subset type %T returned from Value", sv)
74 }
75 nv.Value = sv
76 }
77
78
79
80
81
82
83
84
85 var err error
86 arg := nv.Value
87 nv.Value, err = c.cci.ColumnConverter(index).ConvertValue(arg)
88 if err != nil {
89 return err
90 }
91 if !driver.IsValue(nv.Value) {
92 return fmt.Errorf("driver ColumnConverter error converted %T to unsupported type %T", arg, nv.Value)
93 }
94 return nil
95 }
96
97
98
99
100 func defaultCheckNamedValue(nv *driver.NamedValue) (err error) {
101 nv.Value, err = driver.DefaultParameterConverter.ConvertValue(nv.Value)
102 return err
103 }
104
105
106
107
108
109
110
111 func driverArgsConnLocked(ci driver.Conn, ds *driverStmt, args []any) ([]driver.NamedValue, error) {
112 nvargs := make([]driver.NamedValue, len(args))
113
114
115
116
117 want := -1
118
119 var si driver.Stmt
120 var cc ccChecker
121 if ds != nil {
122 si = ds.si
123 want = ds.si.NumInput()
124 cc.want = want
125 }
126
127
128
129
130
131 nvc, ok := si.(driver.NamedValueChecker)
132 if !ok {
133 nvc, _ = ci.(driver.NamedValueChecker)
134 }
135 cci, ok := si.(driver.ColumnConverter)
136 if ok {
137 cc.cci = cci
138 }
139
140
141
142
143
144
145 var err error
146 var n int
147 for _, arg := range args {
148 nv := &nvargs[n]
149 if np, ok := arg.(NamedArg); ok {
150 if err = validateNamedValueName(np.Name); err != nil {
151 return nil, err
152 }
153 arg = np.Value
154 nv.Name = np.Name
155 }
156 nv.Ordinal = n + 1
157 nv.Value = arg
158
159
160
161
162
163
164
165
166
167
168
169
170 checker := defaultCheckNamedValue
171 nextCC := false
172 switch {
173 case nvc != nil:
174 nextCC = cci != nil
175 checker = nvc.CheckNamedValue
176 case cci != nil:
177 checker = cc.CheckNamedValue
178 }
179
180 nextCheck:
181 err = checker(nv)
182 switch err {
183 case nil:
184 n++
185 continue
186 case driver.ErrRemoveArgument:
187 nvargs = nvargs[:len(nvargs)-1]
188 continue
189 case driver.ErrSkip:
190 if nextCC {
191 nextCC = false
192 checker = cc.CheckNamedValue
193 } else {
194 checker = defaultCheckNamedValue
195 }
196 goto nextCheck
197 default:
198 return nil, fmt.Errorf("sql: converting argument %s type: %w", describeNamedValue(nv), err)
199 }
200 }
201
202
203
204 if want != -1 && len(nvargs) != want {
205 return nil, fmt.Errorf("sql: expected %d arguments, got %d", want, len(nvargs))
206 }
207
208 return nvargs, nil
209 }
210
211
212
213
214
215
216
217
218
219
220
221
222
223 func convertAssign(dest any, src any) error {
224 return convertAssignRows(dest, src, nil)
225 }
226
227
228
229
230
231
232
233
234
235
236
237 func ConvertAssign(scanCtx driver.ScanContext, dest any, src driver.Value) error {
238 rows, _ := internal.ScanContextValue(internal.ScanContext(scanCtx)).(*Rows)
239 return convertAssignRows(dest, src, rows)
240 }
241
242
243
244
245
246
247 func convertAssignRows(dest, src any, rows *Rows) error {
248
249 switch s := src.(type) {
250 case int64:
251 switch d := dest.(type) {
252 case *int64:
253 if d == nil {
254 return errNilPtr
255 }
256 *d = s
257 return nil
258 case *int:
259 if d == nil {
260 return errNilPtr
261 }
262 if int64(int(s)) == s {
263 *d = int(s)
264 return nil
265 }
266
267 }
268 case float64:
269 switch d := dest.(type) {
270 case *float64:
271 if d == nil {
272 return errNilPtr
273 }
274 *d = s
275 return nil
276 }
277 case string:
278 switch d := dest.(type) {
279 case *string:
280 if d == nil {
281 return errNilPtr
282 }
283 *d = s
284 return nil
285 case *[]byte:
286 if d == nil {
287 return errNilPtr
288 }
289 *d = []byte(s)
290 return nil
291 case *RawBytes:
292 if d == nil {
293 return errNilPtr
294 }
295 *d = rows.setrawbuf(append(rows.rawbuf(), s...))
296 return nil
297 case *uuid.UUID:
298 if d == nil {
299 return errNilPtr
300 }
301 u, err := uuid.Parse(s)
302 if err != nil {
303 return fmt.Errorf("converting driver.Value type string (%q) to a UUID: %v", s, err)
304 }
305 *d = u
306 return nil
307 }
308 case []byte:
309 switch d := dest.(type) {
310 case *string:
311 if d == nil {
312 return errNilPtr
313 }
314 *d = string(s)
315 return nil
316 case *any:
317 if d == nil {
318 return errNilPtr
319 }
320 *d = bytes.Clone(s)
321 return nil
322 case *[]byte:
323 if d == nil {
324 return errNilPtr
325 }
326 *d = bytes.Clone(s)
327 return nil
328 case *RawBytes:
329 if d == nil {
330 return errNilPtr
331 }
332 *d = s
333 return nil
334 case *uuid.UUID:
335 if d == nil {
336 return errNilPtr
337 }
338 if len(s) == len(*d) {
339 copy((*d)[:], s)
340 return nil
341 }
342 var u uuid.UUID
343 err := u.UnmarshalText(s)
344 if err != nil {
345 return fmt.Errorf("converting driver.Value type []byte (%q) to a UUID: %v", s, err)
346 }
347 *d = u
348 return nil
349 }
350 case time.Time:
351 switch d := dest.(type) {
352 case *time.Time:
353 *d = s
354 return nil
355 case *string:
356 *d = s.Format(time.RFC3339Nano)
357 return nil
358 case *[]byte:
359 if d == nil {
360 return errNilPtr
361 }
362 *d = s.AppendFormat(make([]byte, 0, len(time.RFC3339Nano)), time.RFC3339Nano)
363 return nil
364 case *RawBytes:
365 if d == nil {
366 return errNilPtr
367 }
368 *d = rows.setrawbuf(s.AppendFormat(rows.rawbuf(), time.RFC3339Nano))
369 return nil
370 }
371 case decimalDecompose:
372 switch d := dest.(type) {
373 case decimalCompose:
374 return d.Compose(s.Decompose(nil))
375 }
376 case nil:
377 switch d := dest.(type) {
378 case *any:
379 if d == nil {
380 return errNilPtr
381 }
382 *d = nil
383 return nil
384 case *[]byte:
385 if d == nil {
386 return errNilPtr
387 }
388 *d = nil
389 return nil
390 case *RawBytes:
391 if d == nil {
392 return errNilPtr
393 }
394 *d = nil
395 return nil
396 }
397
398 case driver.Rows:
399 d, ok := dest.(*Rows)
400 if ok {
401 if d == nil {
402 return errNilPtr
403 }
404 if rows == nil {
405 return errors.New("invalid context to convert cursor rows, missing parent *Rows")
406 }
407
408
409
410
411
412 *d = Rows{
413 dc: rows.dc,
414 releaseConn: func(error) {},
415 rowsi: s,
416 }
417
418
419
420
421
422
423
424
425
426
427
428
429
430 parentCancel := rows.cancel
431 rows.cancel = func() {
432
433
434 d.close(rows.lasterr)
435 if parentCancel != nil {
436 parentCancel()
437 }
438 }
439 return nil
440 }
441 }
442
443 var sv reflect.Value
444
445 switch d := dest.(type) {
446 case *string:
447 sv = reflect.ValueOf(src)
448 switch sv.Kind() {
449 case reflect.Bool,
450 reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64,
451 reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64,
452 reflect.Float32, reflect.Float64:
453 *d = asString(src)
454 return nil
455 }
456 case *[]byte:
457 sv = reflect.ValueOf(src)
458 if b, ok := asBytes(nil, sv); ok {
459 *d = b
460 return nil
461 }
462 case *RawBytes:
463 sv = reflect.ValueOf(src)
464 if b, ok := asBytes(rows.rawbuf(), sv); ok {
465 *d = rows.setrawbuf(b)
466 return nil
467 }
468 case *bool:
469 bv, err := driver.Bool.ConvertValue(src)
470 if err == nil {
471 *d = bv.(bool)
472 }
473 return err
474 case *any:
475 *d = src
476 return nil
477 }
478
479 if scanner, ok := dest.(Scanner); ok {
480 return scanner.Scan(src)
481 }
482
483 dpv := reflect.ValueOf(dest)
484 if dpv.Kind() != reflect.Pointer {
485 return errors.New("destination not a pointer")
486 }
487 if dpv.IsNil() {
488 return errNilPtr
489 }
490
491 if !sv.IsValid() {
492 sv = reflect.ValueOf(src)
493 }
494
495 dv := reflect.Indirect(dpv)
496 if sv.IsValid() && sv.Type().AssignableTo(dv.Type()) {
497 switch b := src.(type) {
498 case []byte:
499 dv.Set(reflect.ValueOf(bytes.Clone(b)))
500 default:
501 dv.Set(sv)
502 }
503 return nil
504 }
505
506 if dv.Kind() == sv.Kind() && sv.Type().ConvertibleTo(dv.Type()) {
507 dv.Set(sv.Convert(dv.Type()))
508 return nil
509 }
510
511
512
513
514
515
516 switch dv.Kind() {
517 case reflect.Pointer:
518 if src == nil {
519 dv.SetZero()
520 return nil
521 }
522 dv.Set(reflect.New(dv.Type().Elem()))
523 return convertAssignRows(dv.Interface(), src, rows)
524 case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
525 if src == nil {
526 return fmt.Errorf("converting NULL to %s is unsupported", dv.Kind())
527 }
528 s := asString(src)
529 i64, err := strconv.ParseInt(s, 10, dv.Type().Bits())
530 if err != nil {
531 err = strconvErr(err)
532 return fmt.Errorf("converting driver.Value type %T (%q) to a %s: %v", src, s, dv.Kind(), err)
533 }
534 dv.SetInt(i64)
535 return nil
536 case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
537 if src == nil {
538 return fmt.Errorf("converting NULL to %s is unsupported", dv.Kind())
539 }
540 s := asString(src)
541 u64, err := strconv.ParseUint(s, 10, dv.Type().Bits())
542 if err != nil {
543 err = strconvErr(err)
544 return fmt.Errorf("converting driver.Value type %T (%q) to a %s: %v", src, s, dv.Kind(), err)
545 }
546 dv.SetUint(u64)
547 return nil
548 case reflect.Float32, reflect.Float64:
549 if src == nil {
550 return fmt.Errorf("converting NULL to %s is unsupported", dv.Kind())
551 }
552 s := asString(src)
553 f64, err := strconv.ParseFloat(s, dv.Type().Bits())
554 if err != nil {
555 err = strconvErr(err)
556 return fmt.Errorf("converting driver.Value type %T (%q) to a %s: %v", src, s, dv.Kind(), err)
557 }
558 dv.SetFloat(f64)
559 return nil
560 case reflect.String:
561 if src == nil {
562 return fmt.Errorf("converting NULL to %s is unsupported", dv.Kind())
563 }
564 switch v := src.(type) {
565 case string:
566 dv.SetString(v)
567 return nil
568 case []byte:
569 dv.SetString(string(v))
570 return nil
571 }
572 }
573
574 return fmt.Errorf("unsupported Scan, storing driver.Value type %T into type %T", src, dest)
575 }
576
577 func strconvErr(err error) error {
578 if ne, ok := err.(*strconv.NumError); ok {
579 return ne.Err
580 }
581 return err
582 }
583
584 func asString(src any) string {
585 switch v := src.(type) {
586 case string:
587 return v
588 case []byte:
589 return string(v)
590 }
591 rv := reflect.ValueOf(src)
592 switch rv.Kind() {
593 case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
594 return strconv.FormatInt(rv.Int(), 10)
595 case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
596 return strconv.FormatUint(rv.Uint(), 10)
597 case reflect.Float64:
598 return strconv.FormatFloat(rv.Float(), 'g', -1, 64)
599 case reflect.Float32:
600 return strconv.FormatFloat(rv.Float(), 'g', -1, 32)
601 case reflect.Bool:
602 return strconv.FormatBool(rv.Bool())
603 }
604 return fmt.Sprintf("%v", src)
605 }
606
607 func asBytes(buf []byte, rv reflect.Value) (b []byte, ok bool) {
608 switch rv.Kind() {
609 case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
610 return strconv.AppendInt(buf, rv.Int(), 10), true
611 case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
612 return strconv.AppendUint(buf, rv.Uint(), 10), true
613 case reflect.Float32:
614 return strconv.AppendFloat(buf, rv.Float(), 'g', -1, 32), true
615 case reflect.Float64:
616 return strconv.AppendFloat(buf, rv.Float(), 'g', -1, 64), true
617 case reflect.Bool:
618 return strconv.AppendBool(buf, rv.Bool()), true
619 case reflect.String:
620 s := rv.String()
621 return append(buf, s...), true
622 }
623 return
624 }
625
626 var valuerReflectType = reflect.TypeFor[driver.Valuer]()
627
628
629
630
631
632
633
634
635
636
637
638
639 func callValuerValue(vr driver.Valuer) (v driver.Value, err error) {
640 if rv := reflect.ValueOf(vr); rv.Kind() == reflect.Pointer &&
641 rv.IsNil() &&
642 rv.Type().Elem().Implements(valuerReflectType) {
643 return nil, nil
644 }
645 return vr.Value()
646 }
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669 type decimal interface {
670 decimalDecompose
671 decimalCompose
672 }
673
674 type decimalDecompose interface {
675
676
677
678 Decompose(buf []byte) (form byte, negative bool, coefficient []byte, exponent int32)
679 }
680
681 type decimalCompose interface {
682
683
684 Compose(form byte, negative bool, coefficient []byte, exponent int32) error
685 }
686
View as plain text