public  void persistent(String word,int value) {  
        
        conn = getConnection(); // 首先要获取连接，即连接到数据库  
  
        try {  
            String sql = "SELECT * FROM stormWordCount where word = '"+word+"'";  
              
            st = (Statement) conn.createStatement();    // 创建用于执行静态sql语句的Statement对象  
              
            ResultSet rs = st.executeQuery(sql);
            if(rs.next()){
            	String count = rs.getString(2);
            	int ct = Integer.parseInt(count)+value;
            	update(word,ct);
            	collector.emit(new Values(word, ct));
            }else{
            	insert(word,value);
            	collector.emit(new Values(word, 1));
            }
              
              
        } catch (SQLException e) {  
            System.out.println("插入数据失败" + e.getMessage());  
        }  
    }