Merge pull request #1 from ultd/batch-write

add batch write method

Author: ultd

client.go

@@ -12,6 +12,7 @@ import (
 	"fmt"
 	"math/big"
 	"net"
+	"strings"
 
 	_ "github.com/lib/pq"
 )
@@ -189,6 +190,35 @@ func (c *Client) Write(a interface{}, options ...option) error {
 	return nil
 }
 
+func (c *Client) WriteBatch(rows []interface{}, options ...option) error {
+	var models []*Model
+	for _, row := range rows {
+		m, err := NewModel(row)
+		if err != nil {
+			return err
+		}
+		if len(options) > 0 {
+			for _, opt := range options {
+				// check and set all options here
+				if opt.tableName != "" {
+					m.tableName = opt.tableName
+				}
+			}
+		}
+		models = append(models, m)
+	}
+
+	var sb strings.Builder
+	for _, m := range models {
+		sb.Write(m.MarshalLine())
+	}
+	_, err := c.ilpConn.Write([]byte(sb.String()))
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
 // DB func returns the underlying *sql.DB struct for DB operations over the Postgres wire protocol
 func (c *Client) DB() *sql.DB {
 	return c.pgSqlDB