Julien Schmidt 10 years ago
parent
commit
618fbd9cc9
5 changed files with 20 additions and 21 deletions
  1. 2 2
      driver.go
  2. 1 1
      errors.go
  3. 2 2
      infile.go
  4. 13 14
      packets.go
  5. 2 2
      utils.go

+ 2 - 2
driver.go

@@ -4,7 +4,7 @@
 // License, v. 2.0. If a copy of the MPL was not distributed with this file,
 // 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/.
 // You can obtain one at http://mozilla.org/MPL/2.0/.
 
 
-// Go MySQL Driver - A MySQL-Driver for Go's database/sql package
+// Package mysql provides a MySQL driver for Go's database/sql package
 //
 //
 // The driver should be used via the database/sql package:
 // The driver should be used via the database/sql package:
 //
 //
@@ -22,7 +22,7 @@ import (
 	"net"
 	"net"
 )
 )
 
 
-// This struct is exported to make the driver directly accessible.
+// MySQLDriver is exported to make the driver directly accessible.
 // In general the driver is used via the database/sql package.
 // In general the driver is used via the database/sql package.
 type MySQLDriver struct{}
 type MySQLDriver struct{}
 
 

+ 1 - 1
errors.go

@@ -32,7 +32,7 @@ var (
 	ErrBusyBuffer        = errors.New("Busy buffer")
 	ErrBusyBuffer        = errors.New("Busy buffer")
 )
 )
 
 
-var errLog Logger = log.New(os.Stderr, "[MySQL] ", log.Ldate|log.Ltime|log.Lshortfile)
+var errLog = Logger(log.New(os.Stderr, "[MySQL] ", log.Ldate|log.Ltime|log.Lshortfile))
 
 
 // Logger is used to log critical error messages.
 // Logger is used to log critical error messages.
 type Logger interface {
 type Logger interface {

+ 2 - 2
infile.go

@@ -175,8 +175,8 @@ func (mc *mysqlConn) handleInFileRequest(name string) (err error) {
 	// read OK packet
 	// read OK packet
 	if err == nil {
 	if err == nil {
 		return mc.readResultOK()
 		return mc.readResultOK()
-	} else {
-		mc.readPacket()
 	}
 	}
+
+	mc.readPacket()
 	return err
 	return err
 }
 }

+ 13 - 14
packets.go

@@ -47,9 +47,8 @@ func (mc *mysqlConn) readPacket() ([]byte, error) {
 		if data[3] != mc.sequence {
 		if data[3] != mc.sequence {
 			if data[3] > mc.sequence {
 			if data[3] > mc.sequence {
 				return nil, ErrPktSyncMul
 				return nil, ErrPktSyncMul
-			} else {
-				return nil, ErrPktSync
 			}
 			}
+			return nil, ErrPktSync
 		}
 		}
 		mc.sequence++
 		mc.sequence++
 
 
@@ -539,13 +538,13 @@ func (mc *mysqlConn) handleOkPacket(data []byte) error {
 	// warning count [2 bytes]
 	// warning count [2 bytes]
 	if !mc.strict {
 	if !mc.strict {
 		return nil
 		return nil
-	} else {
-		pos := 1 + n + m + 2
-		if binary.LittleEndian.Uint16(data[pos:pos+2]) > 0 {
-			return mc.getWarnings()
-		}
-		return nil
 	}
 	}
+
+	pos := 1 + n + m + 2
+	if binary.LittleEndian.Uint16(data[pos:pos+2]) > 0 {
+		return mc.getWarnings()
+	}
+	return nil
 }
 }
 
 
 // Read Packets as Field Packets until EOF-Packet or an Error appears
 // Read Packets as Field Packets until EOF-Packet or an Error appears
@@ -742,13 +741,13 @@ func (stmt *mysqlStmt) readPrepareResultPacket() (uint16, error) {
 		// Warning count [16 bit uint]
 		// Warning count [16 bit uint]
 		if !stmt.mc.strict {
 		if !stmt.mc.strict {
 			return columnCount, nil
 			return columnCount, nil
-		} else {
-			// Check for warnings count > 0, only available in MySQL > 4.1
-			if len(data) >= 12 && binary.LittleEndian.Uint16(data[10:12]) > 0 {
-				return columnCount, stmt.mc.getWarnings()
-			}
-			return columnCount, nil
 		}
 		}
+
+		// Check for warnings count > 0, only available in MySQL > 4.1
+		if len(data) >= 12 && binary.LittleEndian.Uint16(data[10:12]) > 0 {
+			return columnCount, stmt.mc.getWarnings()
+		}
+		return columnCount, nil
 	}
 	}
 	return 0, err
 	return 0, err
 }
 }

+ 2 - 2
utils.go

@@ -642,7 +642,7 @@ func escapeBytesBackslash(buf, v []byte) []byte {
 			pos += 2
 			pos += 2
 		default:
 		default:
 			buf[pos] = c
 			buf[pos] = c
-			pos += 1
+			pos++
 		}
 		}
 	}
 	}
 
 
@@ -687,7 +687,7 @@ func escapeStringBackslash(buf []byte, v string) []byte {
 			pos += 2
 			pos += 2
 		default:
 		default:
 			buf[pos] = c
 			buf[pos] = c
-			pos += 1
+			pos++
 		}
 		}
 	}
 	}