Question

执行 INSERT、UPDATE、DELETE 等无记录返回的操作。

• 方法 Exec 自动释放连接。
• 对结果（ Result ）处理，无需持有连接。

返回自增 Id 和受影响的行数，需数据库和驱动支持。

package main

import (
	"database/sql"
	"log"

	_ "github.com/mattn/go-sqlite3"
)

func main() {
	log.SetFlags(log.Lshortfile)
    
	db, err := sql.Open("sqlite3", "./test.db")
	if err != nil { log.Fatalln(err) }
	defer db.Close()

    // ------------------
    
	q := `INSERT INTO user (id, name) VALUES (?, ?)`

	result, err := db.Exec(q, 3, "u3")
	if err != nil { log.Fatalln(err)  }

    // ------------------

	id, err := result.LastInsertId()
	if err != nil { log.Fatalln(err)  }
	println(id)

	rows, err := result.RowsAffected()
	if err != nil { log.Fatalln(err)  }
	println(rows)
}

源码剖析

在 exec 退出前，释放连接。

// database/sql/sql.go

func (db *DB) exec(ctx, query, args, strategy) (Result, error) {
	dc, err := db.conn(ctx, strategy)
	return db.execDC(ctx, dc, dc.releaseConn, query, args)
}

func (db *DB) execDC(ctx, dc, release, query, args) (res Result, err error) {
    
    // 确保归还连接。
	defer func() {
		release(err)
	}()
    
    // 检查接口实现。
	execerCtx, ok := dc.ci.(driver.ExecerContext)
    
    // 执行！
	if ok {
		withLock(dc, func() {
			resi, err = ctxDriverExec(ctx, execerCtx, execer, query, nvdargs)
		})
        
		if err != driver.ErrSkip {
			if err != nil {
				return nil, err
			}
			return driverResult{dc, resi}, nil
		}
	}

    // 以 Prepare 方式执行。
	withLock(dc, func() {
		si, err = ctxDriverPrepare(ctx, dc.ci, query)
	})
	ds := &driverStmt{Locker: dc, si: si}
	defer ds.Close()
    
	return resultFromStatement(ctx, dc.ci, ds, args...)
}