|
|
@@ -135,7 +135,7 @@ func (c *Client) Transaction(txFunc client.TransactionFunc) error {
|
|
|
}
|
|
|
|
|
|
func (c *Client) Insert(req *client.InsertRequest) (string, error) {
|
|
|
- tableRowJsonBytes, err := c.formTableRow(req.TableRow)
|
|
|
+ tableRow, err := c.formTableRow(req.TableRow)
|
|
|
if err != nil {
|
|
|
return "", err
|
|
|
}
|
|
|
@@ -145,7 +145,7 @@ func (c *Client) Insert(req *client.InsertRequest) (string, error) {
|
|
|
TablePrefixWithSchema: req.TablePrefixWithSchema,
|
|
|
Version: req.Version,
|
|
|
KeyColumns: req.KeyColumns,
|
|
|
- TableRow: tableRowJsonBytes,
|
|
|
+ TableRow: tableRow,
|
|
|
UserID: req.UserID,
|
|
|
})
|
|
|
if err != nil {
|
|
|
@@ -235,7 +235,7 @@ func (c *Client) DeleteBatch(req *client.DeleteBatchRequest) (string, error) {
|
|
|
}
|
|
|
|
|
|
func (c *Client) Update(req *client.UpdateRequest) (string, error) {
|
|
|
- newTableRowJsonByte, err := c.formTableRow(req.NewTableRow)
|
|
|
+ newTableRow, err := c.formTableRow(req.NewTableRow)
|
|
|
if err != nil {
|
|
|
return "", err
|
|
|
}
|
|
|
@@ -245,7 +245,7 @@ func (c *Client) Update(req *client.UpdateRequest) (string, error) {
|
|
|
TablePrefixWithSchema: req.TablePrefixWithSchema,
|
|
|
Version: req.Version,
|
|
|
KeyValues: req.KeyValues,
|
|
|
- NewTableRow: newTableRowJsonByte,
|
|
|
+ NewTableRow: newTableRow,
|
|
|
UserID: req.UserID,
|
|
|
})
|
|
|
if err != nil {
|