Method Exec

storage/storage.go:326–365

Exec implements write query feature.

(ctx context.Context, queries []Query)

// Exec implements write query feature.
func (s *Storage) Exec(ctx context.Context, queries []Query) (result ExecResult, err error) {
	if len(queries) == 0 {
		return
	}

	var tx *sql.Tx
	var txOptions = &sql.TxOptions{
		ReadOnly: false,
	}

	if tx, err = s.db.BeginTx(ctx, txOptions); err != nil {
		return
	}

	defer tx.Rollback()

	for _, q := range queries {
		// convert arguments types
		args := make([]interface{}, len(q.Args))

		for i, v := range q.Args {
			args[i] = v
		}

		var r sql.Result
		if r, err = tx.Exec(q.Pattern, args...); err != nil {
			log.WithError(err).Debug("execute query failed")
			return
		}

		var affected int64
		affected, _ = r.RowsAffected()
		result.RowsAffected += affected
		result.LastInsertID, _ = r.LastInsertId()
	}

	tx.Commit()

	return
}

// Close implements database safe close feature.
func (s *Storage) Close() (err error) {