空间管理您的位置: 51Testing软件测试网 » yayating的个人空间 » 日志

java 连接数据库并查询

上一篇 / 下一篇 2012-07-17 10:09:35 / 个人分类：java应用

package test;

import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import com.mysql.jdbc.*;

public class DataBaseExample {
private Connection conn = null;
private ResultSet rst=null;
private Statement stmt;
// String User = "ws_cbs";
// String Pwd = "wscbs123";
// String dbname = "cbs_ue_manage";
public void getConnection(String User,String Pwd,String dbname) {
try {
Class.forName("com.mysql.jdbc.Driver");

  } catch (ClassNotFoundException e) {
   // TODO Auto-generated catch block
   System.out.println("连接失败");
   e.printStackTrace();
  }
  try {
   this.conn=(Connection) DriverManager.getConnection("jdbc:mysql://192.168.10.240:3306/" + dbname
     + "?user=" + User + "&password=" + Pwd + "");
   System.out.println("连接成功");
//  System.out.println(this.conn);
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }

}
public ResultSet executeQuery(String sql){

//  System.out.println(sql);
  try {
   System.out.println(this.conn);
  stmt = (Statement) conn.createStatement();
  System.out.println("test");

   rst = (ResultSet) stmt.executeQuery(sql);
   System.out.println("查询成功");
  } catch (SQLException e) {
   System.out.println("executeQuery:"+e.getMessage());
   System.out.println("创建statement失败");
  }
  return rst;
}
//获取total_users
public int getResult(ResultSet rst){
  String total_users; //存储由数据库中取出来的total_users
//  String split_total_users[]; //分割后的total_users
  ArrayList unique_total_users=new ArrayList(); //存储去重后的total_users
  int nums=0;
  try {
   while(rst.next())
   {
    total_users=rst.getString("total_users");
//    System.out.println(total_users);
    total_users=total_users.substring(1,total_users.length()-1);
    total_users=total_users.replaceAll("\"", "");
//   System.out.println(total_users);
   String split_total_users[]=total_users.split(",");

   for(int i=0;i<split_total_users.length;i++)
    {
//     System.out.println(split_total_users[i]);

     if(unique_total_users.contains(split_total_users[i])==false)
      unique_total_users.add(split_total_users[i]);
    }

   }
    nums=unique_total_users.size();
   System.out.println(nums);
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  return nums;
}
//获取nums
@SuppressWarnings("unchecked")
public int getResultNums(ResultSet rst){
  String nums; //存储由数据库中取出来的nums
  String split_nums[]; //按照逗号分割后的nums
  ArrayList total_split_nums=new ArrayList(); //按照冒号分割为二维数组
  String temp_nums[];
//  ArrayList total_split_nums=new ArrayList();
//  HashMap total_split_nums = new HashMap();//存储去重后的total_users
  Integer total_nums=0;

  try {
   while(rst.next())
   {
    nums=rst.getString("nums");
//    System.out.println(total_users);
    nums=nums.substring(1,nums.length()-1);
    nums=nums.replaceAll("\"", "");
//   System.out.println(nums);
    split_nums=nums.split(",");
    for(int i=0;i<split_nums.length;i++)
    {
     temp_nums=split_nums[i].split(":");
//    System.out.println(temp_nums[1]);
     total_split_nums.add(temp_nums[1]);
     total_nums=total_nums+Integer.parseInt(temp_nums[1]);
    }
   }

  System.out.println(total_nums);
  } catch (SQLException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  return total_nums;
}

收藏举报

TAG:

查看全部评论

java 连接数据库并查询

用户菜单

我的栏目

标题搜索

日历

我的存档

数据统计

RSS订阅