Function handleInboundSQL

IceFireDB-SQLProxy/internal/mysql/p2p.go:109–147

(m *mysqlProxy, s *p2p.Message, txConn map[string]*client.Conn, accessType string)

}

func handleInboundSQL(m *mysqlProxy, s *p2p.Message, txConn map[string]*client.Conn, accessType string) {
	var err error
	conn, ok := txConn[s.SenderID]

	if !ok {
		// Get appropriate connection based on access type
		if accessType == "admin" {
			conn, err = m.popAdminConn()
		} else {
			conn, err = m.popReadonlyConn()
		}
		if err != nil {
			logrus.Errorf("asyncSQL get %s conn err: %v", accessType, err)
			return
		}
	}

	// Execute query
	_, err = conn.Execute(s.Content)
	if err != nil {
		logrus.Infof("Inbound %s sql: %s err: %v", accessType, s.Content, err)
		return
	}
	logrus.Infof("Inbound %s id: %s, sql: %s", accessType, s.SenderID, s.Content)

	if !ok {
		if conn.IsInTransaction() {
			txConn[s.SenderID] = conn
		} else {
			if accessType == "admin" {
				m.pushAdminConn(conn, err)
			} else {
				m.pushReadonlyConn(conn, err)
			}
		}
	} else if ok && !conn.IsInTransaction() {
		delete(txConn, s.SenderID)
	}
}

var DMLSQL = []string{
	"BEGIN",