x

src/main/java/com/egolm/sentinel/web/SqlConcurrentController.java

@@ -185,8 +185,26 @@ public class SqlConcurrentController {
 		dataSource.setDriverClassName(driverClass);
 		dataSource.setUsername(username);
 		dataSource.setPassword(password);
+		dataSource.setValidationQuery("select 1");
+		dataSource.setValidationQueryTimeout(1000);
 		dataSource.init();
+		
+		int count = 5;
+		while(!dataSource.isInited() && count-- > 0) {
+			try {
+				Thread.sleep(1000L);
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			}
+		}
+		
+		if(dataSource.isInited()) {
 			return dataSource;
+		} else {
+			dataSource.close();
+			return null;
+		}
+		
 	}
 	
 }