这篇文章主要介绍了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!");
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持呐喊教程。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：notice#nhooo.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。