Что такое хороший шаблон для повторного подключения внешних баз данных?

Question

Как я могу эффективно подключиться к внешней базе данных, когда узнаю, что постоянное соединение не работает? Если ExtClient теряет соединение, он вернет «Сломанную трубу» на err.

func ListenForWork(cmdChannel <-chan *WorkCmd) { 
    for { 
     cmd, ok := <- cmdChannel 
     if !ok { 
      break 
     } 
     for { // Retry request until it's OK (`Broken pipe error` might destroy it) 
      _, err := ExtClient.Request(cmd.Key, cmd.Value) 
      if err == nil { 
       break 
      } 
     } 
    } 
} 

Как я могу, из того или иного метода, повторно подключиться эффективным способом? Любые улучшения в этом коде также приветствуются. ExtClient не пересоединяется самостоятельно и является глобальной переменной.

Answer 1

Предполагая, что ExtClient имеет метод Connect или Reconnect.

А также предполагая, что errno BrokenPipe экспортируется как переменная, которую вы можете сопоставить снова.

Тогда это должно работать if err == BrokenPipeErr { ExtClient.Connect(args ...SomeType) }

Это много предположений, хотя, так что вы, вероятно, следует сказать нам немного больше информации, как то, что базы данных вы подключаетесь. Какую клиентскую библиотеку вы используете. И другая такая информация.

Answer 2

Если вы используете mymysql, тогда вы можете использовать auto reconnection interface.

Из документов

import (
    "github.com/ziutek/mymysql/autorc" 
    _ "github.com/ziutek/mymysql/thrsafe" // You may also use the native engine 
) 

// [...] 

db := autorc.New("tcp", "", "127.0.0.1:3306", user, pass, dbname) 

// Initilisation commands. They will be executed after each connect. 
db.Register("set names utf8") 

// There is no need to explicity connect to the MySQL server 
rows, res, err := db.Query("SELECT * FROM R") 
checkError(err) 

// Now we are connected. 

// It does not matter if connection will be interrupted during sleep, eg 
// due to server reboot or network down. 

сказанных, от чтения sql docs и sql driver docs и соответствующего кода, похоже, что если драйвер SQL возвращает ErrBadConn то пакет SQL будет повторить с новым соединением. Это было добавлено только в июле 2012 года, поэтому, возможно, пока не поддерживается драйверами SQL.