updates

Author: dveeden

client/conn.go

@@ -508,7 +508,6 @@ func (c *Conn) exec_send(query string) error {
 			}
 			c.queryAttributes = append(c.queryAttributes, lineAttr)
 		}
-
 	}
 
 	if c.capability&CLIENT_QUERY_ATTRIBUTES > 0 {
@@ -675,6 +674,7 @@ func (c *Conn) StatusString() string {
 	return strings.Join(stats, "|")
 }
 
+// SetQueryAttributes sets the query attributes to be send along with the next query
 func (c *Conn) SetQueryAttributes(attrs ...QueryAttribute) error {
 	c.queryAttributes = attrs
 	return nil

client/stmt.go

@@ -74,7 +74,6 @@ func (s *Stmt) write(args ...interface{}) error {
 			}
 			s.conn.queryAttributes = append(s.conn.queryAttributes, lineAttr)
 		}
-
 	}
 
 	qaLen := len(s.conn.queryAttributes)

mysql/queryattributes.go

@@ -23,7 +23,7 @@ func (qa *QueryAttribute) TypeAndFlag() []byte {
 	case string:
 		return []byte{MYSQL_TYPE_STRING, 0x0}
 	case uint64:
-		return []byte{MYSQL_TYPE_LONGLONG, UNSIGNED_FLAG}
+		return []byte{MYSQL_TYPE_LONGLONG, PARAM_UNSIGNED}
 	default:
 		log.Warnf("query attribute with unsupported type %T", v)
 	}