|
@@ -237,8 +237,8 @@ func (d *DB) Insert(query string, args interface{}) (LastInsertId, RowsAffected
|
|
return
|
|
return
|
|
}
|
|
}
|
|
defer d.Close()
|
|
defer d.Close()
|
|
-
|
|
|
|
- if rs, err := d.conn.NamedExec(query, args); err == nil {
|
|
|
|
|
|
+ var rs sql.Result
|
|
|
|
+ if rs, err = d.conn.NamedExec(query, args); err == nil {
|
|
LastInsertId, _ = rs.LastInsertId()
|
|
LastInsertId, _ = rs.LastInsertId()
|
|
RowsAffected, _ = rs.RowsAffected()
|
|
RowsAffected, _ = rs.RowsAffected()
|
|
}
|
|
}
|
|
@@ -253,7 +253,8 @@ func (d *DB) Update(query string, args interface{}) (RowsAffected int64, err err
|
|
}
|
|
}
|
|
defer d.Close()
|
|
defer d.Close()
|
|
|
|
|
|
- if rs, err := d.conn.NamedExec(query, args); err == nil {
|
|
|
|
|
|
+ var rs sql.Result
|
|
|
|
+ if rs, err = d.conn.NamedExec(query, args); err == nil {
|
|
RowsAffected, _ = rs.RowsAffected()
|
|
RowsAffected, _ = rs.RowsAffected()
|
|
}
|
|
}
|
|
return
|
|
return
|