java一个数据整理的方法代码实例
这篇文章主要介绍了java一个数据整理的方法代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
importjava.sql.*; publicclassMain{ //本地数据库 //staticfinalStringJDBC_DRIVER="com.mysql.jdbc.Driver"; //staticfinalStringDB_URL="jdbc:mysql://127.0.0.1:3306/aite?useSSL=false&serverTimezone=UTC"; //staticfinalStringUSER="root"; //staticfinalStringPASS="root"; //测试服务器数据库 staticfinalStringJDBC_DRIVER="com.mysql.jdbc.Driver"; staticfinalStringDB_URL="jdbc:mysql://192.168.1.236:3306/aite?useSSL=false&serverTimezone=UTC"; staticfinalStringUSER="root"; staticfinalStringPASS="c6f20omhhg"; publicstaticvoidmain(String[]args){ //Connectionconn=null; //Statementstmt=null; //Statementstmt2=null; //try{ //Class.forName(JDBC_DRIVER); //System.out.println("连接数据库..."); //conn=DriverManager.getConnection(DB_URL,USER,PASS); //System.out.println("实例化Statement对象..."); //stmt=conn.createStatement(); //Stringsql; //sql="SELECTid,id2FROMsys_code_regionwhereid2>736978"; //ResultSetrs=stmt.executeQuery(sql); //inta=2; //while(rs.next()){ //Stringid=rs.getString("id"); ////Stringname=rs.getString("id2"); //intb=rs.getInt("id2"); //Stringsql2; //sql2="updatebase_areasetarea_code="+id+"whereid='"+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(SQLExceptionse){ //se.printStackTrace(); //}catch(Exceptione){ //e.printStackTrace(); //}finally{ //try{ //if(stmt!=null)stmt.close(); //}catch(SQLExceptionse2){ //} //try{ //if(conn!=null)conn.close(); //}catch(SQLExceptionse){ //se.printStackTrace(); //} //} //System.out.println("Success!"); //getPids(); setPriority(); } /** *pids查询插入递归方法 */ publicstaticvoidgetPids(){ Connectionconn=null; Statementstmt=null; Statementstmt2=null; Stringpids=null; try{ Class.forName(JDBC_DRIVER); System.out.println("连接数据库..."); conn=DriverManager.getConnection(DB_URL,USER,PASS); System.out.println("实例化Statement对象..."); stmt=conn.createStatement(); Stringsql; sql="SELECTid,pid,nameFROMbase_areawhereid=2210"; ResultSetrs=stmt.executeQuery(sql); while(rs.next()){ Stringstr1=rs.getString("id"); Stringstr2=rs.getString("pid"); Stringstr3=rs.getString("name"); inta=Integer.parseInt(str1); intb=Integer.parseInt(str2); pids=str2; intc=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(); Stringsql2; sql2="updatebase_areasetpids='"+pids+"'whereid="+a; stmt2.execute(sql2); System.out.println("id:"+a+",name:"+str3+",pids:"+pids); } rs.close(); stmt.close(); conn.close(); }catch(SQLExceptionse){ se.printStackTrace(); }catch(Exceptione){ e.printStackTrace(); }finally{ try{ if(stmt!=null)stmt.close(); }catch(SQLExceptionse2){ } try{ if(conn!=null)conn.close(); }catch(SQLExceptionse){ se.printStackTrace(); } } System.out.println("Success!"); } /** *pid查询方法 *@paramid *@returnpid */ publicstaticIntegergetPid(intid){ Connectionconn3=null; Statementstmt3=null; intpid=0; try{ conn3=DriverManager.getConnection(DB_URL,USER,PASS); stmt3=conn3.createStatement(); Stringsql3="selectpidfrombase_areawhereid="+id; ResultSetrs3=stmt3.executeQuery(sql3); while(rs3.next()){ Stringstr=rs3.getString("pid"); pid=Integer.parseInt(str); } rs3.close(); stmt3.close(); conn3.close(); }catch(SQLExceptionse){ se.printStackTrace(); }catch(Exceptione){ e.printStackTrace(); }finally{ try{ if(stmt3!=null)stmt3.close(); }catch(SQLExceptionse2){ } try{ if(conn3!=null)conn3.close(); }catch(SQLExceptionse){ se.printStackTrace(); } } returnpid; } /** *排序方法 */ publicstaticvoidsetPriority(){ try{ System.out.println("连接数据库..."); Connectionconn4=DriverManager.getConnection(DB_URL,USER,PASS); System.out.println("实例化Statement对象..."); Statementstmt4=conn4.createStatement(); ResultSetrs4=stmt4.executeQuery("selectidfrombase_area"); while(rs4.next()){ intid=rs4.getInt("id"); Statementstmt5=conn4.createStatement(); Stringsqlstr1="selectid,pidfrombase_areawherepid="+id+"ORDERBYid"; ResultSetrs5=stmt5.executeQuery(sqlstr1); rs5.last(); intcount=rs5.getRow(); if(count>0){ rs5.beforeFirst(); inti=1; while(rs5.next()){ intid2=rs5.getInt("id"); Statementstmt6=conn4.createStatement(); Stringsqlstr2="updatebase_areasetpriority="+i+"whereid="+id2; stmt6.execute(sqlstr2); System.out.println("id:"+id2+",priority:"+i); i++; } } //System.out.println(id); } } catch(SQLExceptionse){ se.printStackTrace(); } catch(Exceptione){ e.printStackTrace(); } System.out.println("Complete!"); } }
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。