updates

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)
 }