项目mysql数据导入数据的Java程序

最近写的一个数据库导入数据的程序，有兴趣的同学可以参考一下：

这个程序是针对mysql数据库的，在本地或服务器上运行，主要的需求还是，针对项目的某些bug修复

后，客户的数据要搬到新表上来，避免新版本上线或发布后用户的数据丢失，里面有Json格式的字段，不太好处理。

视频具体效果预览：http://www.polyv.net/about/news/2013/0922/142.html

package com.ibatis.test;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.security.interfaces.RSAKey;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.aspectj.weaver.patterns.ThisOrTargetAnnotationPointcut;

import ayou.util.DOC;

import com.cc.ovp.domain.PlayProfile;
import com.cc.ovp.domain.PlayerSkin;
import com.cc.ovp.domain.PlayerSkin.Ext;




 public class PlayerskinToPlayerprofile {
     
        private static Connection connection; 
        private static Statement statement; 
        private static ResultSet resultSet; 
        private ResultSetMetaData rsMetaData; 
        
        
       ////构造函数
        public PlayerskinToPlayerprofile(){
            
            String url = "jdbc:mysql://127.0.0.1:3306/xuan?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull"; 
            String username = "root"; 
            String password = "123456";
            //加载驱动程序以连接数据库
            try { 
                Class.forName( "org.gjt.mm.mysql.Driver" ); 
                connection = DriverManager.getConnection(url, username, password ); 
            } 
            //捕获加载驱动程序异常
            catch ( ClassNotFoundException cnfex ) { 
                System.err.println("装载 JDBC/ODBC 驱动程序失败"); 
                cnfex.printStackTrace(); 
            } 
            //捕获连接数据库异常
            catch ( SQLException sqlex ) { 
                System.err.println( "无法连接数据库" ); 
                sqlex.printStackTrace(); 
           }
               
        }
        
        
        ///////////////////////////////
        @SuppressWarnings("unchecked")
        private static void getTable2() throws IOException 
        { 
        try { 
            //执行SQL语句
            //String query = inputQuery.getText(); 
            statement = connection.createStatement(); 
            resultSet = statement.executeQuery("select * from player_skin;"); 
            //在表格中显示查询结果
      
           //DOC[] docs= resultSet;
         /*   List list=(List)resultSet;
            PlayerSkin palyerSkin=new PlayerSkin(); 
            System.out.println("记录数===="+list.size());
            for(int i=0; i<list.size();i++){
                System.out.println(i+"========"+palyerSkin.getPlayerid()+"====="+palyerSkin.getUserid());
            }*/
            PlayerSkin palyerSkin2=new PlayerSkin(); 
            PlayerSkin.Ext ext=new Ext();
            BufferedWriter bw=new BufferedWriter(new FileWriter("home/qixuan/playerSkinExtToplayProfile.txt"));
            int j=0;
            while(resultSet.next()){
                j++;
                
               //System.out.println("======"+extTo);
                    try {
                        String extTo=resultSet.getString("ext");
                        ext=(PlayerSkin.Ext.fromJSON(extTo));
                    } catch (Exception e) {
                        
                        try {
                            bw.write("userid---"+resultSet.getString("userid"));
                            bw.newLine();
                            bw.flush();
                            
                        } catch (IOException e1) {
                            // TODO Auto-generated catch block
                            e1.printStackTrace();
                        }
                     // TODO Auto-generated catch block
                        e.printStackTrace();
                       
                    }
                    
                
                System.out.println(j+"========"+resultSet.getString("playerid")
                        +"====="+resultSet.getString("userid")
                        +"===D==="+ext.getWatermark_show()
                        +"===E==="+ext.getWatermarklocation()
                        +"===r==="+ext.getWatermark_diaph()
                        +"===q==="+ext.getWatermarkurl1()
                        +"===y==="+ext.getWatermarkurl2()
                        +"===u==="+ext.getWatermarkurl3()
                        +"===j==="+ext.getAutoplay()                 
                        +"===w==="+ext.getDefinition());
                        //+"==EXT==="+resultSet.getString("ext"));
              
              
                //System.out.println(j+"=========="+ext.getDisable_host()+"=========="+ext.getEnable_host());
                
                DOC doc3 = new DOC();

                String userid3= resultSet.getString("userid");
                
                List<PlayProfile> playProfiles=selectDate2(userid3);
                
                if(playProfiles.size()>0){
                    //System.out.println("===数据===="+playProfiles.get(0).getExt());
                    doc3 = com.cc.ovp.util.Ext.parseJson(playProfiles.get(0).getExt());
                    
                    //doc3.put("definition", "1");
                    //doc3.put("width", "600");
                    //doc3.put("autoplay",ext.getAutoplay());
                    doc3.put("watermarklocation",ext.getWatermarklocation());
                    doc3.put("watermark_show",ext.getWatermark_show());
                    doc3.put("watermark_diaph",ext.getWatermark_diaph());
                    doc3.put("watermarkurl1",ext.getWatermarkurl1());
                    doc3.put("watermarkurl2",ext.getWatermarkurl2());
                    doc3.put("watermarkurl3",ext.getWatermarkurl3());
                    
                    String ext3 = com.cc.ovp.util.Ext.setJson(doc3);
                    //System.out.println("ext3::::::::::::::"+ext3);
                    updateDate2(userid3,ext3);//更新数据
                   
                }else{
                    
                    doc3.put("definition", "1");
                    doc3.put("width", "600");
                    doc3.put("height", "0");
                    doc3.put("autoplay","1");
                    doc3.put("watermarklocation",ext.getWatermarklocation());
                    doc3.put("watermark_show",ext.getWatermark_show());
                    doc3.put("watermark_diaph",ext.getWatermark_diaph());
                    doc3.put("watermarkurl1",ext.getWatermarkurl1());
                    doc3.put("watermarkurl2",ext.getWatermarkurl2());
                    doc3.put("watermarkurl3",ext.getWatermarkurl3());
                    
                    String ext3 = com.cc.ovp.util.Ext.setJson(doc3);
                    //System.out.println("ext3::::::::::::::"+ext3);
                    insertDate2(resultSet.getString("userid"),ext3);//插入数据
                }

                
                
            }
            bw.close();
            resultSet.close();
            statement.close();
            //connection.close();
           
        } 
        catch ( SQLException sqlex ) {
              sqlex.printStackTrace(); 
           } 
       } 
        
        
        
        ////查询play_profile表的数据
        @SuppressWarnings("unchecked")
        public static List<PlayProfile> selectDate2(String userid3) throws SQLException{

            //statement=connection.createStatement();
            PreparedStatement ps=connection.prepareStatement("select * from play_profile where userid=?");
            ps.setString(1,userid3);
            ResultSet rs=ps.executeQuery();
            List<PlayProfile> list=new ArrayList<PlayProfile>();
            while(rs.next()){
              PlayProfile playProfile = new PlayProfile();
              playProfile.setUserid(rs.getString("userid"));
              playProfile.setAutoid(rs.getInt("autoid"));
              playProfile.setExt(rs.getString("ext"));
              playProfile.setStatus(rs.getInt("status"));
              list.add(playProfile);
            }
            ps.close();
       
            return list;
        }
        
        ////插入数据
        public static void insertDate2(String userid,String ext3) throws SQLException{
           
            PreparedStatement ps=connection.prepareStatement("insert into play_profile(userid,status,ext) values(?,?,?)");
            ps.setString(1,userid);
            ps.setInt(2, 60);
            ps.setString(3, ext3);
            ps.executeUpdate();
            ps.close();
            
        }
        
        ////更新数据
        public static void updateDate2(String userid,String ext3) throws SQLException{
            PreparedStatement ps=connection.prepareStatement("update play_profile set ext=? where userid=?");
            ps.setString(1, ext3);
            ps.setString(2, userid);
            ps.executeUpdate();
            ps.close();      
        }
        
        
        
        public static void main(String[] args) throws IOException{
            PlayerskinToPlayerprofile ptp=new PlayerskinToPlayerprofile();
            ptp.getTable2();
          
            //System.out.println("程序入口");
        }
  
}///////////

运行效果

这里只给出控制台运行情况：

预览地址：http://www.polyv.net/about/news/2013/0922/142.html