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

这个程序是针对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 blocke1.printStackTrace();}// TODO Auto-generated catch blocke.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

转载于:https://www.cnblogs.com/james1207/p/3339694.html

项目mysql数据导入数据的Java程序相关推荐

  1. python批量导入mysql_用python批量向数据库(MySQL)中导入数据

    用python批量向数据库(MySQL)中导入数据 现有数十万条数据,如下的经过打乱处理过的数据进行导入 数据库内部的表格的数据格式如下与下面的表格结构相同 Current database: pyt ...

  2. python 数据导入mysql_用python批量向数据库(MySQL)中导入数据

    用python批量向数据库(MySQL)中导入数据 现有数十万条数据,如下的经过打乱处理过的数据进行导入 数据库内部的表格的数据格式如下与下面的表格结构相同Current database: pyth ...

  3. mysql数据库导入数据的几种方式

    mysql数据库导入数据的几种方式 适用于大量数据的导入 一.excel方式导入 1.将需要的数据放到表格中,需要注意表格中的列必须与要导入的表保持一致 2.导入步骤 二.csv文件导入 1.一般拿到 ...

  4. MySQL快速导入数据

    今天分享的是mysql中导入数据的一个方法 load data INFILE,这个方法比一般的insert要快,废话不多说直接上手. 导入数据 在这里注意一下写路径的时候斜线一定要是双斜线. 数据的要 ...

  5. R语言 零基础入门教程第11章 Rattle可视化数据挖掘工具(1)Rattle简介及安装 功能预览 数据导入 数据探索 数据建模 模型评估 Rattle实例

    关注公众号凡花花的小窝,收获更多的考研计算机专业编程相关的资料 本章内容 Rattle简介及安装 功能预览 数据导入 数据探索 数据建模 模型评估 Rattle实例 本章目标 了解Rattle的安装及 ...

  6. java mysql 文本导入数据语句_Java利用MYSQL LOAD DATA LOCAL INFILE实现大批量导入数据到MySQL...

    Mysql load data的使用 数据库中,最常见的写入数据方式是通过SQL INSERT来写入,另外就是通过备份文件恢复数据库,这种备份文件在MySQL中是SQL脚本,实际上执行的还是在批量IN ...

  7. mye连接mysql数据库_MySQL_如何在Java程序中访问mysql数据库中的数据并进行简单的操作,在上篇文章给大家介绍了Myeclip - phpStudy...

    如何在Java程序中访问mysql数据库中的数据并进行简单的操作 在上篇文章给大家介绍了Myeclipse连接mysql数据库的方法,通过本文给大家介绍如何在Java程序中访问mysql数据库中的数据 ...

  8. insert时调用本身字段_「技术篇」ETL工具Kettle数据对比同步以及Java程序中调用

    作为一个技术栈出身的攻城狮,虽然走上管理之路,但是技术是不能扔下的,时不时的拿起来重温一下,理论与实践相结合... 使用背景: 住建部某区块链共享平台(下游系统)需要自于上游系统的生产库数据,数据量不 ...

  9. 如何在MySQL中导入数据

    首先,你需要提前准备好一个mysql数据文件,文件名后缀为sql的文件(当然数据需要你提前准备好在里面,就拿电商网页项目来说,你需要商品分类,商品管理,用户登录,商品数量等等的数据库,这些都是需要你提 ...

最新文章

  1. 【控制】《鲁棒控制-线性矩阵不等式处理方法》-俞立老师-目录
  2. 演讲 | 微软亚洲研究院刘铁岩:对偶学习推动人工智能的新浪潮
  3. 【emWin】例程十六:窗口管理器
  4. python中object转str_Python-TypeError:无法将“ int”对象隐式转换为str
  5. NuttX 启动流程
  6. 查看xxx.a库架构的命令
  7. 工业机器人导轨 百度文库_工业机器人或许开创一个全新的PLC时代
  8. Linux 7.x 防火墙端口
  9. 栈在表达式求值中的应用
  10. Android基站定位——单基站定位(二)
  11. JavaScript基础---字符串方法
  12. [原创]Java开发如何在线打开Word文件
  13. VB图像识别、语音识别源代码+注释
  14. Tableau Desktop 2021中文免费版下载(包含其它历史版本)
  15. 论文润色软件Stylewriter,whitesmoke,1check使用亲测
  16. 《深度学习》之 VGG卷积神经网络 原理 详解
  17. 流利阅读12.31 The science of giving gifts your loved ones won’t want to return
  18. بۇر بىر سىناق
  19. 城市园区NB-IoT智慧井盖解决方案
  20. 开年福利!微服务前后端开发手册,打造完美全栈工程师

热门文章

  1. 【软件测试】POST请求包含哪些参数
  2. python机械臂仿真_使用VTK与Python实现机械臂三维模型可视化
  3. 未转变者2.2.4怎么创建服务器,未转变者2period;2period;4墙怎么做 | 手游网游页游攻略大全...
  4. 如何绘制物理图谱和遗传图谱的对应关系
  5. oa系统php面试问题,oa系统是什么?
  6. css 侧栏跟随_简单代码实现智能侧边栏跟随固定浮动的效果
  7. python绘制分形图形_Python绘制L-System的分形图
  8. java做安卓文本编辑器,android文本编辑器
  9. WeLink互动直播:维护网课秩序,杜绝外人乱入
  10. IRIS的镜像配置(2)