ColumnType interfaces #667
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,152 @@ | ||
| // Go MySQL Driver - A MySQL-Driver for Go's database/sql package | ||
| // | ||
| // Copyright 2017 The Go-MySQL-Driver Authors. All rights reserved. | ||
| // | ||
| // This Source Code Form is subject to the terms of the Mozilla Public | ||
| // License, v. 2.0. If a copy of the MPL was not distributed with this file, | ||
| // You can obtain one at http://mozilla.org/MPL/2.0/. | ||
|
|
||
| package mysql | ||
|
|
||
| import ( | ||
| "database/sql" | ||
| "reflect" | ||
| "time" | ||
| ) | ||
|
|
||
| var typeDatabaseName = map[fieldType]string{ | ||
| fieldTypeDecimal: "DECIMAL", | ||
| fieldTypeTiny: "TINYINT", | ||
| fieldTypeShort: "SMALLINT", | ||
| fieldTypeLong: "INT", | ||
| fieldTypeFloat: "FLOAT", | ||
| fieldTypeDouble: "DOUBLE", | ||
| fieldTypeNULL: "NULL", | ||
| fieldTypeTimestamp: "TIMESTAMP", | ||
| fieldTypeLongLong: "BIGINT", | ||
| fieldTypeInt24: "MEDIUMINT", | ||
| fieldTypeDate: "DATE", | ||
| fieldTypeTime: "TIME", | ||
| fieldTypeDateTime: "DATETIME", | ||
| fieldTypeYear: "YEAR", | ||
| fieldTypeNewDate: "DATE", | ||
| fieldTypeVarChar: "VARCHAR", | ||
| fieldTypeBit: "BIT", | ||
| fieldTypeJSON: "JSON", | ||
| fieldTypeNewDecimal: "DECIMAL", | ||
| fieldTypeEnum: "ENUM", | ||
| fieldTypeSet: "SET", | ||
| fieldTypeTinyBLOB: "TINYBLOB", | ||
| fieldTypeMediumBLOB: "MEDIUMBLOB", | ||
| fieldTypeLongBLOB: "LONGBLOB", | ||
| fieldTypeBLOB: "BLOB", | ||
| fieldTypeVarString: "VARCHAR", | ||
| fieldTypeString: "CHAR", | ||
| fieldTypeGeometry: "GEOMETRY", | ||
| } | ||
|
|
||
| var ( | ||
| scanTypeNil = reflect.TypeOf(nil) | ||
| scanTypeNullInt = reflect.TypeOf(sql.NullInt64{}) | ||
| scanTypeUint8 = reflect.TypeOf(uint8(0)) | ||
| scanTypeInt8 = reflect.TypeOf(int8(0)) | ||
| scanTypeUint16 = reflect.TypeOf(uint16(0)) | ||
| scanTypeInt16 = reflect.TypeOf(int16(0)) | ||
| scanTypeUint32 = reflect.TypeOf(uint32(0)) | ||
| scanTypeInt32 = reflect.TypeOf(int32(0)) | ||
| scanTypeUint64 = reflect.TypeOf(uint64(0)) | ||
| scanTypeInt64 = reflect.TypeOf(int64(0)) | ||
| scanTypeNullFloat = reflect.TypeOf(sql.NullFloat64{}) | ||
| scanTypeFloat32 = reflect.TypeOf(float32(0)) | ||
| scanTypeFloat64 = reflect.TypeOf(float64(0)) | ||
| scanTypeNullString = reflect.TypeOf(sql.NullString{}) | ||
| scanTypeString = reflect.TypeOf("") | ||
| scanTypeBytes = reflect.TypeOf([]byte{}) | ||
| scanTypeRawBytes = reflect.TypeOf(sql.RawBytes{}) | ||
| scanTypeTime = reflect.TypeOf(time.Time{}) | ||
| scanTypeNullTime = reflect.TypeOf(NullTime{}) | ||
| scanTypeUnknown = reflect.TypeOf(new(interface{})) | ||
| ) | ||
|
|
||
| type mysqlField struct { | ||
| tableName string | ||
| name string | ||
| flags fieldFlag | ||
| fieldType fieldType | ||
| decimals byte | ||
| } | ||
|
|
||
| func (mf *mysqlField) scanType(parseTime bool) reflect.Type { | ||
| switch mf.fieldType { | ||
| case fieldTypeNULL: | ||
| return scanTypeNil | ||
|
|
||
| case fieldTypeTiny: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| if mf.flags&flagUnsigned != 0 { | ||
| return scanTypeUint8 | ||
| } | ||
| return scanTypeInt8 | ||
| } | ||
| return scanTypeNullInt | ||
|
|
||
| case fieldTypeShort, fieldTypeYear: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| if mf.flags&flagUnsigned != 0 { | ||
| return scanTypeUint16 | ||
| } | ||
| return scanTypeInt16 | ||
| } | ||
| return scanTypeNullInt | ||
|
|
||
| case fieldTypeInt24, fieldTypeLong: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| if mf.flags&flagUnsigned != 0 { | ||
| return scanTypeUint32 | ||
| } | ||
| return scanTypeInt32 | ||
| } | ||
| return scanTypeNullInt | ||
|
|
||
| case fieldTypeLongLong: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| if mf.flags&flagUnsigned != 0 { | ||
| return scanTypeUint64 | ||
| } | ||
| return scanTypeInt64 | ||
| } | ||
| return scanTypeNullInt | ||
|
|
||
| case fieldTypeFloat: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| return scanTypeFloat32 | ||
| } | ||
| return scanTypeNullFloat | ||
|
|
||
| case fieldTypeDouble: | ||
| if mf.flags&flagNotNULL != 0 { | ||
| return scanTypeFloat64 | ||
| } | ||
| return scanTypeNullFloat | ||
|
|
||
| case fieldTypeDecimal, fieldTypeNewDecimal, fieldTypeVarChar, | ||
| fieldTypeBit, fieldTypeEnum, fieldTypeSet, fieldTypeTinyBLOB, | ||
| fieldTypeMediumBLOB, fieldTypeLongBLOB, fieldTypeBLOB, | ||
| fieldTypeVarString, fieldTypeString, fieldTypeGeometry, fieldTypeJSON, | ||
| fieldTypeTime: | ||
| return scanTypeRawBytes | ||
|
There was a problem hiding this comment. Do I have to check nullable to decide converting to sql.NullString or string myself? There was a problem hiding this comment.
|
||
|
|
||
| case fieldTypeDate, fieldTypeNewDate, | ||
| fieldTypeTimestamp, fieldTypeDateTime: | ||
| if parseTime { | ||
| if mf.flags&flagNotNULL != 0 { | ||
| return scanTypeTime | ||
| } | ||
| return scanTypeNullTime | ||
| } | ||
| return scanTypeRawBytes | ||
|
|
||
| default: | ||
| return scanTypeUnknown | ||
| } | ||
| } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm not convinced this helps taking all the casting happening in packets.go ...