@@ -287,10 +287,10 @@ protected void alterTableName(String tableName, String newTableName)
287287 }
288288
289289 protected void closeConnections () {
290- Map <Thread , Connection > connectionMap = _companyConnectionMap .get (
290+ Map <Thread , Connection > connectionsMap = _companyConnectionsMap .get (
291291 CompanyThreadLocal .getCompanyId ());
292292
293- _closeConnections (connectionMap );
293+ _closeConnections (connectionsMap );
294294 }
295295
296296 /**
@@ -504,12 +504,12 @@ protected void removePrimaryKey(String tableName) throws Exception {
504504
505505 protected Connection connection ;
506506
507- private void _closeConnections (Map <Thread , Connection > connectionMap ) {
508- if (MapUtil .isEmpty (connectionMap )) {
507+ private void _closeConnections (Map <Thread , Connection > connectionsMap ) {
508+ if (MapUtil .isEmpty (connectionsMap )) {
509509 return ;
510510 }
511511
512- Collection <Connection > connections = connectionMap .values ();
512+ Collection <Connection > connections = connectionsMap .values ();
513513
514514 try {
515515 Iterator <Connection > iterator = connections .iterator ();
@@ -589,10 +589,10 @@ private Connection _getConnection() {
589589 private int _getConnectionsCount () {
590590 int connectionsCount = 0 ;
591591
592- for (Map <Thread , Connection > connectionMap :
593- _companyConnectionMap .values ()) {
592+ for (Map <Thread , Connection > connectionsMap :
593+ _companyConnectionsMap .values ()) {
594594
595- connectionsCount += connectionMap .size ();
595+ connectionsCount += connectionsMap .size ();
596596 }
597597
598598 return connectionsCount ;
@@ -734,7 +734,7 @@ private <T> void _processConcurrently(
734734
735735 private static final Log _log = LogFactoryUtil .getLog (BaseDBProcess .class );
736736
737- private final Map <Long , Map <Thread , Connection >> _companyConnectionMap =
737+ private final Map <Long , Map <Thread , Connection >> _companyConnectionsMap =
738738 new ConcurrentHashMap <>();
739739
740740 private class ConnectionThreadProxyInvocationHandler
@@ -748,23 +748,23 @@ public Object invoke(Object proxy, Method method, Object[] args)
748748
749749 if (methodName .equals ("close" )) {
750750 if (_getConnectionsCount () > 0 ) {
751- for (Map <Thread , Connection > connectionMap :
752- _companyConnectionMap .values ()) {
751+ for (Map <Thread , Connection > connectionsMap :
752+ _companyConnectionsMap .values ()) {
753753
754- _closeConnections (connectionMap );
754+ _closeConnections (connectionsMap );
755755 }
756756 }
757757
758758 return null ;
759759 }
760760
761- Map <Thread , Connection > connectionMap =
762- _companyConnectionMap .computeIfAbsent (
761+ Map <Thread , Connection > connectionsMap =
762+ _companyConnectionsMap .computeIfAbsent (
763763 CompanyThreadLocal .getCompanyId (),
764764 key -> new ConcurrentHashMap <>());
765765
766766 return method .invoke (
767- connectionMap .computeIfAbsent (
767+ connectionsMap .computeIfAbsent (
768768 Thread .currentThread (), thread -> _getConnection ()),
769769 args );
770770 }
0 commit comments