(query string)
| 81 | } |
| 82 | |
| 83 | func trackGoID(query string) { |
| 84 | thisGoID := goid() |
| 85 | if _, ok := goidToWriter.Load(thisGoID); ok { |
| 86 | return // we're on a writer goroutine |
| 87 | } |
| 88 | |
| 89 | q := strings.TrimSpace(query) |
| 90 | if strings.HasPrefix(q, "SELECT") { |
| 91 | return // SELECTs can go on other goroutines |
| 92 | } |
| 93 | logrus.Warnf("unsafe goid %d: SQL executed not on an ExclusiveWriter: %s", thisGoID, q) |
| 94 | } |
| 95 | |
| 96 | func init() { |
| 97 | registerDrivers() |
no test coverage detected