基于neo4j的保险智能咨询系统源码+项目说明.zip

package com.appleyk.service.impl; import com.appleyk.database.JDBCKit; import com.appleyk.node.Insurance; import com.appleyk.service.InsuranceService; import org.springframework.context.annotation.Primary; import org.springframework.stereotype.Service; import javax.swing.*; import java.io.*; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @Service @Primary public class InsuranceServiceImpl implements InsuranceService { //获取所有的保险类型的id @Override public List<Integer> getAllTypes(){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; List<Integer> listNum = new ArrayList<Integer>(); try{ connection = JDBCKit.getConnection(); String sql="SELECT type_id FROM type;"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); while(resultSet.next()){ int Num = resultSet.getInt("type_id"); listNum.add(Num); } return listNum; } catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //获取所有的保险公司id @Override public List<Integer> getAllComs(){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; List<Integer> listNum = new ArrayList<Integer>(); try{ connection = JDBCKit.getConnection(); String sql="SELECT company_id FROM company;"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); while(resultSet.next()){ int Num = resultSet.getInt("company_id"); listNum.add(Num); } return listNum; } catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //根据公司name获取公司id @Override public Integer ComIdToName(int Com_nam){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; try{ connection = JDBCKit.getConnection(); String sql="SELECT company_id FROM company where company_name = " + Com_nam + ";"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); int id = resultSet.getInt("company_id"); return id; } catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //根据保险类型id获得name @Override public String typeIdToName(int type_id){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; try{ connection = JDBCKit.getConnection(); String sql="SELECT type_name FROM type where type_id = " + type_id + ";"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); String Name = null; while(resultSet.next()) { Name = resultSet.getString("type_name"); } return Name; } catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //根据指定保险类型返回保险的数量 @Override public Integer getAllComInNum(int Type_id){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; int Num = 0; try{ connection = JDBCKit.getConnection(); String sql="select count(insurance_id) as Num from insurance where insurance_typeid = " + Type_id + ";"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); while(resultSet.next()){ Num = resultSet.getInt("Num"); } return Num; }catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //根据保险的名字获取保险信息 @Override public Insurance getInByName(String name){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; Insurance insurance = new Insurance(); try{ connection = JDBCKit.getConnection(); String sql="select * from insurance where insurance_name = \""+name+"\";"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); while(resultSet.next()){ System.out.println(resultSet.getString("insurance_toubaonianling")); insurance.setIn_toubaonianling(resultSet.getString("insurance_toubaonianling")); insurance.setIn_kuanxianqi(resultSet.getString("insurance_kuanxianqi")); insurance.setIn_youyuqi(resultSet.getString("insurance_youyuqi")); insurance.setIn_zerentiaokuan(resultSet.getString("insurance_zerentiaokuan")); insurance.setIn_mianzetiaokuan(resultSet.getString("insurance_mianzetiaokuan")); insurance.setIn_jiaofeifangshi(resultSet.getString("insurance_jiaofeifangshi")); insurance.setIn_baoxianqijian(resultSet.getString("insurance_baoxianqijian")); insurance.setIn_shouyiren(resultSet.getString("insurance_shouyiren")); } return insurance; }catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //返还所有公司每一类保险的数量(返回值map：type_name,InsuranceNum) @Override public Map<String,Integer> getInNumByTypes(){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; //每个类型保险的数量 Map<String ,Integer> NumByTypes = new HashMap<String, Integer>(); //获取保险的所有类型id List<Integer> getAllTypes = getAllTypes(); try{ connection = JDBCKit.getConnection(); //遍历所有类型 for(int i = 0;i < getAllTypes.size();i++){ int type_id = getAllTypes.get(i); String sql="SELECT COUNT(insurance_id) as NUM FROM insurance where insurance_typeid = " + type_id + ";"; statement=connection.prepareStatement(sql); resultSet = statement.executeQuery(); while(resultSet.next()){ String type_name = typeIdToName(type_id); System.out.println(type_name); int Num = resultSet.getInt("NUM"); NumByTypes.put(type_name,Num); } } return NumByTypes; } catch (Exception ex){ ex.printStackTrace(); JDBCKit.release(resultSet, null, connection); return null; } } //返回指定id公司旗下每一类保险的数量(返回值map：type_name,InsuranceNum) @Override public Map<String,Integer> getComInsurNumByTypes(int Com_id){ Connection connection= null; ResultSet resultSet=null; PreparedStatement statement=null; Map<String ,Integer> get