mysql

var LogFormatter = func(values ...interface{}) (messages []interface{}) {
	if len(values) > 1 {
		var (
			sql             string
			formattedValues []string
			level           = values[0]
			currentTime     = "\n\033[33m[" + NowFunc().Format("2006-01-02 15:04:05") + "]\033[0m"
			source          = fmt.Sprintf("\033[35m(%v)\033[0m", values[1])
		)

		messages = []interface{}{source, currentTime}

		if level != "sql" {
			messages = append(messages, "\033[31;1m")
			messages = append(messages, values[2:]...)
			messages = append(messages, "\033[0m")

			return
		}

		for _, value := range values[3].([]interface{}) {
			indirectValue := reflect.Indirect(reflect.ValueOf(value))
			value = indirectValue.Interface()

			if !indirectValue.IsValid() {
				formattedValues = append(formattedValues, "NULL")
			}

			switch value.(type) {
			case time.Time:
				formattedValues = append(formattedValues, fmt.Sprintf("'%v'", value.(time.Time).Format("2006-01-02 15:04:05")))
			case []byte:
				if str := string(value.([]byte)); isPrintable(str) {
					formattedValues = append(formattedValues, fmt.Sprintf("'%v'", str))
				} else {
					formattedValues = append(formattedValues, "'<binary>'")
				}
			case driver.Valuer:
				if value, err := value.(driver.Valuer).Value(); err == nil && value != nil {
					formattedValues = append(formattedValues, fmt.Sprintf("'%v'", value))
				} else {
					formattedValues = append(formattedValues, "NULL")
				}
			default:
				formattedValues = append(formattedValues, fmt.Sprintf("'%v'", value))
			}
		}

		if numericPlaceHolderRegexp.MatchString(values[2].(string)) {
			sql = values[3].(string)
			for index, value := range formattedValues {
				placeholder := fmt.Sprintf(`\$%d([^\d]|$)`, index+1)
				sql = regexp.MustCompile(placeholder).ReplaceAllString(sql, value+"$1")
			}
		} else {
			formattedValuesLength := len(formattedValues)
			for index, value := range sqlRegexp.Split(values[2].(string), -1) {
				sql += value
				if index < formattedValuesLength {
					sql += formattedValues[index]
				}
			}
		}

		messages = append(messages, sql)
	}

	return
}

var NowFunc = func() time.Time {
	return time.Now()
}