feat: fix init panic (apache#540)

Author: georgehao

Diff for: pkg/datasource/sql/xa_resource_manager.go

@@ -82,48 +82,36 @@ type XAResourceManager struct {
 }
 
 func (xaManager *XAResourceManager) xaTwoPhaseTimeoutChecker() {
-	var dbResource *DBResource
-	xaManager.resourceCache.Range(func(key, value any) bool {
-		if source, ok := value.(*DBResource); ok {
-			dbResource = source
-		}
-		return false
-	})
-
-	if dbResource.IsShouldBeHeld() {
-		ticker := time.NewTicker(time.Second)
-		for {
-			select {
-			case <-ticker.C:
-				xaManager.resourceCache.Range(func(key, value any) bool {
-					source, ok := value.(*DBResource)
-					if !ok {
-						return true
-					}
-					if source.IsShouldBeHeld() {
+	ticker := time.NewTicker(time.Second)
+	for {
+		select {
+		case <-ticker.C:
+			xaManager.resourceCache.Range(func(key, value any) bool {
+				source, ok := value.(*DBResource)
+				if !ok {
+					return true
+				}
+				if source.IsShouldBeHeld() {
+					return true
+				}
+
+				source.GetKeeper().Range(func(key, value any) bool {
+					connectionXA, isConnectionXA := value.(*XAConn)
+					if !isConnectionXA {
 						return true
 					}
 
-					source.GetKeeper().Range(func(key, value any) bool {
-						connectionXA, isConnectionXA := value.(*XAConn)
-						if !isConnectionXA {
-							return true
+					if time.Now().Sub(connectionXA.prepareTime) > xaManager.config.TwoPhaseHoldTime {
+						if err := connectionXA.CloseForce(); err != nil {
+							log.Errorf("Force close the xa xid:%s physical connection fail", connectionXA.txCtx.XID)
 						}
-
-						if time.Now().Sub(connectionXA.prepareTime) > xaManager.config.TwoPhaseHoldTime {
-							if err := connectionXA.CloseForce(); err != nil {
-								log.Errorf("Force close the xa xid:%s physical connection fail", connectionXA.txCtx.XID)
-							}
-						}
-						return true
-					})
+					}
 					return true
 				})
-			}
+				return true
+			})
 		}
-
 	}
-
 }
 
 func (xaManager *XAResourceManager) GetBranchType() branch.BranchType {