forked from linxGnu/mssqlx
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy patherrors.go
56 lines (48 loc) · 1.19 KB
/
errors.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
package mssqlx
import (
"database/sql/driver"
"fmt"
"os"
"strings"
"time"
)
// ERROR 1213: Deadlock found when trying to get lock
func isDeadlock(err error) (v bool) {
if err != nil {
se := err.Error()
v = strings.HasPrefix(se, "Error 1213:") || strings.HasPrefix(se, "ERROR 1213:")
}
return
}
// ERROR 1047: WSREP has not yet prepared node for application use
func isWsrepNotReady(err error) (v bool) {
if err != nil {
se := err.Error()
v = strings.HasPrefix(se, "Error 1047:") || strings.HasPrefix(se, "ERROR 1047:")
}
return
}
// check bad connection
func isErrBadConn(err error) (v bool) {
if err != nil {
// Postgres/Mysql Driver returns default driver.ErrBadConn
// Mysql Driver ("github.com/go-sql-driver/mysql") is not
s := err.Error()
v = err == driver.ErrBadConn || s == "invalid connection" || s == "bad connection"
}
return
}
func parseError(w *wrapper, err error) error {
if err == nil {
return nil
}
if w != nil && ping(w) != nil {
return ErrNetwork
}
return err
}
func reportError(v string, err error) {
if err != nil {
os.Stderr.WriteString(fmt.Sprintf("mssqlx;;%s;;%s;;%s;;%s\n", time.Now().Format("2006-01-02 15:04:05"), hostName, v, err.Error()))
}
}