clean up sql code

store/cmd_hist.go

@@ -21,14 +21,17 @@ func init() {
 
 func addLastAmongDup(tx *sql.Tx) error {
 	// Upgrade from early version where lastAmongDup is missing.
-	rows, err := tx.Query("pragma table_info(cmd)")
+	rows, err := tx.Query("select * from cmd limit 1")
 	if err != nil {
 		return err
 	}
+	defer rows.Close()
+
 	hasLastAmongDup, err := hasColumn(rows, "lastAmongDup")
 	if err != nil {
 		return err
 	}
+
 	if !hasLastAmongDup {
 		_, err := tx.Exec("alter table cmd add column lastAmongDup bool")
 		if err != nil {
@@ -39,7 +42,7 @@ func addLastAmongDup(tx *sql.Tx) error {
 			return err
 		}
 	}
-	return tx.Commit()
+	return nil
 }
 
 // NextCmdSeq returns the next sequence number of the command history.

store/sqlutil.go

@@ -7,19 +7,8 @@ func hasColumn(rows *sql.Rows, colname string) (bool, error) {
 	if err != nil {
 		return false, err
 	}
-	dests := make([]interface{}, len(cols))
+	for _, col := range cols {
-	var name string
+		if col == colname {
-	for i, col := range cols {
-		if col == "name" {
-			dests[i] = &name
-		} else {
-			dests[i] = new(interface{})
-		}
-	}
-	defer rows.Close()
-	for rows.Next() {
-		rows.Scan(dests...)
-		if name == colname {
 			return true, nil
 		}
 	}
@@ -35,9 +24,9 @@ func transaction(db *sql.DB, f func(*sql.Tx) error) error {
 	}
 	err = f(tx)
 	if err != nil {
-		tx.Rollback()
+		return tx.Rollback()
 	} else {
-		tx.Commit()
+		return tx.Commit()
 	}
 	return err
 }