使用Storm实现实时大数据分析!

    {  
  •         Class.forName(dbClass);  
  •     }   
  •     catch (ClassNotFoundException e)   
  •     {  
  •         System.out.println("Driver not found");  
  •         e.printStackTrace();  
  •     }  
  •    
  •     try   
  •     {  
  •        connection driverManager.getConnection(   
  •            "jdbc:mysql://"+databaseIP+":"+databasePort+"/"+databaseName, userName, pwd);