Выбор и обновление параллелизма MYSQL

Question

Я не могу понять, как выбрать, а затем обновить таблицу с несколькими программами.В документации для db и stmt говорится: «безопасно для одновременного использования несколькими программами».Также я использую трансакции, но безуспешно.Я хочу начать 7 горутин и взять каждый ряд.

Данные

+--------+-----------+---------------------+
| idTest | someValue | date                |
+--------+-----------+---------------------+
|      1 | 1         | 2019-06-11 11:29:42 |
|      2 | 2         | 2019-06-11 11:29:42 |
|      3 | 3         | NULL                |
|      4 | 4         | NULL                |
|      5 | 5         | NULL                |
|      6 | 6         | NULL                |
|      7 | 7         | NULL                |
+--------+-----------+---------------------+

текущий код

db, err := sql.Open("mysql", strConn)
if err != nil {
    fmt.Printf("Troubles in connaction! %s", err)
}

var idTest int
var someValue string

stmt, err := db.Prepare("select idTest,someValue from test where date is null limit 1")
CheckError(err)

defer stmt.Close()

rows, err := stmt.Query()
CheckError(err)

defer rows.Close()

for rows.Next() {
    rows.Scan(&idTest, &someValue)

    stmt, err = db.Prepare("update test set date = now() where idTest= ?")
    CheckError(err)
    _, err = stmt.Exec(idTest)
    CheckError(err)
}

Каждая программа имеет db.conn и иногда пытается выбрать и обновить таблицу.

func main() {
    for i := 0; i < 7; i++ {
        dbConn := "blabla"
        go ChildBot(dbConn)
    }
    var input string
    fmt.Scanln(&input)
}

Answer 1

Вы должны прочитать данные, а затем запустить программу.

for rows.Next() {
    rows.Scan(&idTest, &someValue)
    go func(idTest int) {
         stmt, err = db.Prepare("update test set date = now() where idTest= ?")
         CheckError(err)
         _, err = stmt.Exec(idTest)
         CheckError(err)
    }(idTest)
}

Это сделано так, потому что вы должны сначала прочитать данные, прежде чем что-то делать с ними.В противном случае при следующем чтении время от времени может быть отменено ваше предыдущее значение.