项目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 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程序相关推荐
- python批量导入mysql_用python批量向数据库(MySQL)中导入数据
用python批量向数据库(MySQL)中导入数据 现有数十万条数据,如下的经过打乱处理过的数据进行导入 数据库内部的表格的数据格式如下与下面的表格结构相同 Current database: pyt ...
- python 数据导入mysql_用python批量向数据库(MySQL)中导入数据
用python批量向数据库(MySQL)中导入数据 现有数十万条数据,如下的经过打乱处理过的数据进行导入 数据库内部的表格的数据格式如下与下面的表格结构相同Current database: pyth ...
- mysql数据库导入数据的几种方式
mysql数据库导入数据的几种方式 适用于大量数据的导入 一.excel方式导入 1.将需要的数据放到表格中,需要注意表格中的列必须与要导入的表保持一致 2.导入步骤 二.csv文件导入 1.一般拿到 ...
- MySQL快速导入数据
今天分享的是mysql中导入数据的一个方法 load data INFILE,这个方法比一般的insert要快,废话不多说直接上手. 导入数据 在这里注意一下写路径的时候斜线一定要是双斜线. 数据的要 ...
- R语言 零基础入门教程第11章 Rattle可视化数据挖掘工具(1)Rattle简介及安装 功能预览 数据导入 数据探索 数据建模 模型评估 Rattle实例
关注公众号凡花花的小窝,收获更多的考研计算机专业编程相关的资料 本章内容 Rattle简介及安装 功能预览 数据导入 数据探索 数据建模 模型评估 Rattle实例 本章目标 了解Rattle的安装及 ...
- java mysql 文本导入数据语句_Java利用MYSQL LOAD DATA LOCAL INFILE实现大批量导入数据到MySQL...
Mysql load data的使用 数据库中,最常见的写入数据方式是通过SQL INSERT来写入,另外就是通过备份文件恢复数据库,这种备份文件在MySQL中是SQL脚本,实际上执行的还是在批量IN ...
- mye连接mysql数据库_MySQL_如何在Java程序中访问mysql数据库中的数据并进行简单的操作,在上篇文章给大家介绍了Myeclip - phpStudy...
如何在Java程序中访问mysql数据库中的数据并进行简单的操作 在上篇文章给大家介绍了Myeclipse连接mysql数据库的方法,通过本文给大家介绍如何在Java程序中访问mysql数据库中的数据 ...
- insert时调用本身字段_「技术篇」ETL工具Kettle数据对比同步以及Java程序中调用
作为一个技术栈出身的攻城狮,虽然走上管理之路,但是技术是不能扔下的,时不时的拿起来重温一下,理论与实践相结合... 使用背景: 住建部某区块链共享平台(下游系统)需要自于上游系统的生产库数据,数据量不 ...
- 如何在MySQL中导入数据
首先,你需要提前准备好一个mysql数据文件,文件名后缀为sql的文件(当然数据需要你提前准备好在里面,就拿电商网页项目来说,你需要商品分类,商品管理,用户登录,商品数量等等的数据库,这些都是需要你提 ...
最新文章
- 【控制】《鲁棒控制-线性矩阵不等式处理方法》-俞立老师-目录
- 演讲 | 微软亚洲研究院刘铁岩:对偶学习推动人工智能的新浪潮
- 【emWin】例程十六:窗口管理器
- python中object转str_Python-TypeError:无法将“ int”对象隐式转换为str
- NuttX 启动流程
- 查看xxx.a库架构的命令
- 工业机器人导轨 百度文库_工业机器人或许开创一个全新的PLC时代
- Linux 7.x 防火墙端口
- 栈在表达式求值中的应用
- Android基站定位——单基站定位(二)
- JavaScript基础---字符串方法
- [原创]Java开发如何在线打开Word文件
- VB图像识别、语音识别源代码+注释
- Tableau Desktop 2021中文免费版下载(包含其它历史版本)
- 论文润色软件Stylewriter,whitesmoke,1check使用亲测
- 《深度学习》之 VGG卷积神经网络 原理 详解
- 流利阅读12.31 The science of giving gifts your loved ones won’t want to return
- بۇر بىر سىناق
- 城市园区NB-IoT智慧井盖解决方案
- 开年福利!微服务前后端开发手册,打造完美全栈工程师
热门文章
- 【软件测试】POST请求包含哪些参数
- python机械臂仿真_使用VTK与Python实现机械臂三维模型可视化
- 未转变者2.2.4怎么创建服务器,未转变者2period;2period;4墙怎么做 | 手游网游页游攻略大全...
- 如何绘制物理图谱和遗传图谱的对应关系
- oa系统php面试问题,oa系统是什么?
- css 侧栏跟随_简单代码实现智能侧边栏跟随固定浮动的效果
- python绘制分形图形_Python绘制L-System的分形图
- java做安卓文本编辑器,android文本编辑器
- WeLink互动直播:维护网课秩序,杜绝外人乱入
- IRIS的镜像配置(2)