Function runExec

go/executor/sql_stmt.go:130–147

(wr *pipe.Writer, slct string, db *database.DB)

}

func runExec(wr *pipe.Writer, slct string, db *database.DB) error {
	res, e := db.Exec(slct)
	if e != nil {
		return fmt.Errorf("runExec failed: %v", e)
	}
	affected, e := res.RowsAffected()
	if e != nil {
		return fmt.Errorf("failed to get affected row number: %v", e)
	}
	if affected > 1 {
		return wr.Write(fmt.Sprintf("%d rows affected", affected))
	}
	// gomaxcompute does not return affected rows number
	if affected < 0 {
		return wr.Write("OK")
	}
	return wr.Write(fmt.Sprintf("%d row affected", affected))
}

// -------------------------- utilities --------------------------------------