inser.go

//  Insert using sql.DB with transaction


func InsertPage(db *sql.DB, url string, content string) error {
	// Open transaction
	tx, err := db.Begin()
	if err != nil {
		return err
	}

	//  Prepare statement
	stmt, err := tx.Prepare("INSERT INTO pages (url, content) values(?, ?)")
	if err != nil {
		rollbackErr := tx.Rollback()
		if rollbackErr != nil {
			return err
		}
		return err
	}
	defer stmt.Close()

	// Exacute statement
	_, err = stmt.Exec(url, content)
	if err != nil {
		rollbackErr := tx.Rollback()
		if rollbackErr != nil {
			return err
		}
		return err
	}

	// Finish transaction
	err = tx.Commit()
	if err != nil {
		rollbackErr := tx.Rollback()
		if rollbackErr != nil {
			return err
		}

		return err
	}

	return nil
}