123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127 |
- package logger
- import (
- "database/sql/driver"
- "fmt"
- "reflect"
- "regexp"
- "strconv"
- "strings"
- "time"
- "unicode"
- "gorm.io/gorm/utils"
- )
- func isPrintable(s []byte) bool {
- for _, r := range s {
- if !unicode.IsPrint(rune(r)) {
- return false
- }
- }
- return true
- }
- var convertableTypes = []reflect.Type{reflect.TypeOf(time.Time{}), reflect.TypeOf(false), reflect.TypeOf([]byte{})}
- func ExplainSQL(sql string, numericPlaceholder *regexp.Regexp, escaper string, avars ...interface{}) string {
- var convertParams func(interface{}, int)
- var vars = make([]string, len(avars))
- convertParams = func(v interface{}, idx int) {
- switch v := v.(type) {
- case bool:
- vars[idx] = strconv.FormatBool(v)
- case time.Time:
- if v.IsZero() {
- vars[idx] = escaper + "0000-00-00 00:00:00" + escaper
- } else {
- vars[idx] = escaper + v.Format("2006-01-02 15:04:05.999") + escaper
- }
- case *time.Time:
- if v != nil {
- if v.IsZero() {
- vars[idx] = escaper + "0000-00-00 00:00:00" + escaper
- } else {
- vars[idx] = escaper + v.Format("2006-01-02 15:04:05.999") + escaper
- }
- } else {
- vars[idx] = "NULL"
- }
- case fmt.Stringer:
- reflectValue := reflect.ValueOf(v)
- if v != nil && reflectValue.IsValid() && ((reflectValue.Kind() == reflect.Ptr && !reflectValue.IsNil()) || reflectValue.Kind() != reflect.Ptr) {
- vars[idx] = escaper + strings.Replace(fmt.Sprintf("%v", v), escaper, "\\"+escaper, -1) + escaper
- } else {
- vars[idx] = "NULL"
- }
- case driver.Valuer:
- reflectValue := reflect.ValueOf(v)
- if v != nil && reflectValue.IsValid() && ((reflectValue.Kind() == reflect.Ptr && !reflectValue.IsNil()) || reflectValue.Kind() != reflect.Ptr) {
- r, _ := v.Value()
- convertParams(r, idx)
- } else {
- vars[idx] = "NULL"
- }
- case []byte:
- if isPrintable(v) {
- vars[idx] = escaper + strings.Replace(string(v), escaper, "\\"+escaper, -1) + escaper
- } else {
- vars[idx] = escaper + "<binary>" + escaper
- }
- case int, int8, int16, int32, int64, uint, uint8, uint16, uint32, uint64:
- vars[idx] = utils.ToString(v)
- case float64, float32:
- vars[idx] = fmt.Sprintf("%.6f", v)
- case string:
- vars[idx] = escaper + strings.Replace(v, escaper, "\\"+escaper, -1) + escaper
- default:
- rv := reflect.ValueOf(v)
- if v == nil || !rv.IsValid() || rv.Kind() == reflect.Ptr && rv.IsNil() {
- vars[idx] = "NULL"
- } else if valuer, ok := v.(driver.Valuer); ok {
- v, _ = valuer.Value()
- convertParams(v, idx)
- } else if rv.Kind() == reflect.Ptr && !rv.IsZero() {
- convertParams(reflect.Indirect(rv).Interface(), idx)
- } else {
- for _, t := range convertableTypes {
- if rv.Type().ConvertibleTo(t) {
- convertParams(rv.Convert(t).Interface(), idx)
- return
- }
- }
- vars[idx] = escaper + strings.Replace(fmt.Sprint(v), escaper, "\\"+escaper, -1) + escaper
- }
- }
- }
- for idx, v := range avars {
- convertParams(v, idx)
- }
- if numericPlaceholder == nil {
- var idx int
- var newSQL strings.Builder
- for _, v := range []byte(sql) {
- if v == '?' {
- if len(vars) > idx {
- newSQL.WriteString(vars[idx])
- idx++
- continue
- }
- }
- newSQL.WriteByte(v)
- }
- sql = newSQL.String()
- } else {
- sql = numericPlaceholder.ReplaceAllString(sql, "$$$1$$")
- for idx, v := range vars {
- sql = strings.Replace(sql, "$"+strconv.Itoa(idx+1)+"$", v, 1)
- }
- }
- return sql
- }
|