INNER CODE UNIT · Go

func

sqldef/sqldef · database/database.go:310

func (r *ddlRunner) begin() error {
	if r.transaction != nil {
		return nil
	}
	transaction, err := r.conn.BeginTx(context.Background(), nil)
	if err != nil {
		return err
	}
	r.transaction = transaction
	r.logger.Printf("%s;\n", r.txQueries.Begin)
	return nil
}

func (r *ddlRunner) commit() error {
	if r.transaction == nil {
		return nil
	}
	transaction := r.transaction

View source record →