这篇文章主要介绍了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!"); }}

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