java一个数据整理的方法代码实例

这篇文章主要介绍了java一个数据整理的方法代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

import java.sql.*;

public class Main {
//本地数据库
// static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
// static final String DB_URL = "jdbc:mysql://127.0.0.1:3306/aite?useSSL=false&serverTimezone=UTC";
// static final String USER = "root";
// static final String PASS = "root";

//测试服务器数据库
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://192.168.1.236:3306/aite?useSSL=false&serverTimezone=UTC";
static final String USER = "root";
static final String PASS = "c6f20omhhg";

public static void main(String[] args) {
// Connection conn = null;
// Statement stmt = null;
// Statement stmt2 = null;
// try{
//   Class.forName(JDBC_DRIVER);
//   System.out.println("连接数据库...");
//   conn = DriverManager.getConnection(DB_URL,USER,PASS);
//   System.out.println(" 实例化Statement对象...");
//   stmt = conn.createStatement();
//   String sql;
//   sql = "SELECT id,id2 FROM sys_code_region where id2>736978";
//   ResultSet rs = stmt.executeQuery(sql);
//   int a=2;
//   while(rs.next()){
//     String id= rs.getString("id");
//     //String name = rs.getString("id2");
//     int b=rs.getInt("id2");
//     String sql2;
//     sql2= "update base_area set area_code="+id+" where id='"+b+"'";
//     stmt2 = conn.createStatement();
//     //stmt2.executeQuery(sql2);
//     stmt2.execute(sql2);
//     a++;
//     System.out.print("ID: " + id);
//     System.out.print(", id2: " + b);
//     System.out.print("\n");
//   }
//   rs.close();
//   stmt.close();
//   conn.close();
// }catch(SQLException se){
//   se.printStackTrace();
// }catch(Exception e){
//   e.printStackTrace();
// }finally{
//  try{
//     if(stmt!=null) stmt.close();
//   }catch(SQLException se2){
//   }
//   try{
//     if(conn!=null) conn.close();
//   }catch(SQLException se){
//     se.printStackTrace();
//   }
// }
// System.out.println("Success!");

//getPids();

setPriority();
}

/**
* pids查询插入递归方法
*/
public static void getPids(){
Connection conn = null;
Statement stmt = null;
Statement stmt2 = null;
String pids=null;
try{
Class.forName(JDBC_DRIVER);
System.out.println("连接数据库...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);
System.out.println(" 实例化Statement对象...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id,pid,name FROM base_area where id=2210";
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()){
String str1=rs.getString("id");
String str2=rs.getString("pid");
String str3=rs.getString("name");
int a =Integer.parseInt(str1);
int b =Integer.parseInt(str2);
pids=str2;
int c=0;
c=getPid(b);
if (c>0){
do{
if (c >1) {
pids = c + "," + pids;
c = getPid(c);
}
}while (c>1);
pids = c + "," + pids;
}
stmt2 = conn.createStatement();
String sql2;
sql2= "update base_area set pids='"+pids+"' where id="+a;
stmt2.execute(sql2);
System.out.println("id: "+a+",name:"+str3+", pids: "+pids);
}
rs.close();
stmt.close();
conn.close();
}catch(SQLException se){
se.printStackTrace();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(stmt!=null) stmt.close();
}catch(SQLException se2){
}
try{
if(conn!=null) conn.close();
}catch(SQLException se){
se.printStackTrace();
}
}
System.out.println("Success!");
}

/**
* pid 查询方法
* @param id
* @return pid
*/
public static Integer getPid(int id){
Connection conn3 = null;
Statement stmt3 = null;
int pid =0;
try{
conn3= DriverManager.getConnection(DB_URL,USER,PASS);
stmt3=conn3.createStatement();
String sql3="select pid from base_area where id="+id;
ResultSet rs3=stmt3.executeQuery(sql3);
while (rs3.next()) {
String str = rs3.getString("pid");
pid = Integer.parseInt(str);
}
rs3.close();
stmt3.close();
conn3.close();
}catch(SQLException se){
se.printStackTrace();
}catch(Exception e){
e.printStackTrace();
}finally{
try{
if(stmt3!=null) stmt3.close();
}catch(SQLException se2){
}
try{
if(conn3!=null) conn3.close();
}catch(SQLException se){
se.printStackTrace();
}

}
return pid;
}

/**
* 排序方法
*/
public static void setPriority(){
try {
System.out.println("连接数据库...");
Connection conn4 = DriverManager.getConnection(DB_URL, USER, PASS);
System.out.println(" 实例化Statement对象...");
Statement stmt4 = conn4.createStatement();
ResultSet rs4 = stmt4.executeQuery("select id from base_area ");
while (rs4.next()){
int id = rs4.getInt("id");
Statement stmt5=conn4.createStatement();
String sqlstr1="select id,pid from base_area where pid="+id+" ORDER BY id ";
ResultSet rs5=stmt5.executeQuery(sqlstr1);
rs5.last();
int count=rs5.getRow();
if(count>0) {
rs5.beforeFirst();
int i=1;
while (rs5.next()) {
int id2 = rs5.getInt("id");
Statement stmt6 = conn4.createStatement();
String sqlstr2="update base_area set priority=" + i + " where id=" + id2;
stmt6.execute(sqlstr2);
System.out.println("id:" + id2 + ", priority:" + i);
i++;
}
}
//System.out.println(id);
}
}
catch (SQLException se){
se.printStackTrace();
}
catch (Exception e){
e.printStackTrace();
}
System.out.println("Complete!");
}
}

以上就是本文的全部内容，希望对大家的学习有所帮助

您可能感兴趣的文章:

• struts2数据处理_动力节点Java学院整理
• 数据库连接池c3p0配置_动力节点Java学院整理
• 深入理解Java运行时数据区_动力节点Java学院整理
• Java数据结构之图(动力节点Java学院整理)
• Java数据结构之数组(动力节点之Java学院整理)
• Java数据结构之散列表(动力节点Java学院整理)
• Java数据结构之队列(动力节点Java学院整理)