query: verify bind errors

Author: Kulezi

query.go

@@ -17,6 +17,7 @@ type Query struct {
 	asyncExec   func(context.Context, *transport.Conn, transport.Statement, frame.Bytes, transport.ResponseHandler)
 	res         []transport.ResponseHandler
 	retryPolicy transport.RetryPolicy
+	err         []error
 }
 
 func (q *Query) Prepare(ctx context.Context) error {
@@ -32,6 +33,9 @@ func (q *Query) Prepare(ctx context.Context) error {
 }
 
 func (q *Query) Exec(ctx context.Context) (Result, error) {
+	if q.err != nil {
+		return Result{}, fmt.Errorf("query can't be executed: %v", q.err)
+	}
 	info, err := q.info()
 	if err != nil {
 		return Result{}, err
@@ -166,7 +170,30 @@ func (q *Query) info() (transport.QueryInfo, error) {
 	return q.session.cluster.NewQueryInfo(), nil
 }
 
+func (q *Query) checkBounds(pos int) error {
+	if q.stmt.Metadata != nil {
+		if pos < 0 || pos >= len(q.stmt.Values) {
+			return fmt.Errorf("no bind marker with position %d", pos)
+		}
+
+		return nil
+	}
+
+	for i := len(q.stmt.Values); i <= pos; i++ {
+		q.stmt.Values = append(q.stmt.Values, frame.Value{})
+	}
+	return nil
+}
+
 func (q *Query) BindInt64(pos int, v int64) *Query {
+	if err := q.checkBounds(pos); err != nil {
+		q.err = append(q.err, err)
+		return q
+	}
+	if q.stmt.Metadata != nil && q.stmt.Metadata.Columns[pos].Type.ID != frame.BigIntID {
+		q.err = append(q.err, fmt.Errorf("can't bind int64 to column of type BigInt"))
+	}
+
 	p := &q.stmt.Values[pos]
 	if p.N == 0 {
 		p.N = 8