Function TestTransaction

client/conn_test.go:171–283

(t *testing.T)

}

func TestTransaction(t *testing.T) {
	Convey("test transaction", t, func() {
		var stopTestService func()
		var err error
		stopTestService, _, err = startTestService()
		So(err, ShouldBeNil)
		defer stopTestService()

		var db *sql.DB
		db, err = sql.Open("covenantsql", "covenantsql://db")
		So(db, ShouldNotBeNil)
		So(err, ShouldBeNil)

		var execResult sql.Result
		var lastInsertID, affectedRows int64

		_, err = db.Exec("create table test (test int)")
		So(err, ShouldBeNil)
		execResult, err = db.Exec("insert into test values (1)")
		So(err, ShouldBeNil)
		lastInsertID, err = execResult.LastInsertId()
		So(err, ShouldBeNil)
		So(lastInsertID, ShouldEqual, 1)
		affectedRows, err = execResult.RowsAffected()
		So(affectedRows, ShouldEqual, 1)

		// test start transaction
		var tx *sql.Tx
		tx, err = db.Begin()
		So(tx, ShouldNotBeNil)
		So(err, ShouldBeNil)

		// test fill invalid read query in transaction
		_, err = tx.Query("select * from test")
		So(err, ShouldNotBeNil)

		// test query
		_, err = tx.Exec("insert into test values(2)")
		So(err, ShouldBeNil)

		// test rollback
		err = tx.Rollback()
		So(err, ShouldBeNil)

		testRowCount := func(expected int) {
			var row *sql.Row
			var err error
			var result int
			row = db.QueryRow("select count(1) as cnt from test")
			So(row, ShouldNotBeNil)
			err = row.Scan(&result)
			So(err, ShouldBeNil)
			So(result, ShouldEqual, expected)
		}

		// test row count on rollback
		testRowCount(1)