zoukankan      html  css  js  c++  java
  • Oracle表导入Mysql方法

        public void reportPerInfo(){
            //每次导入清除之前数据 
            this.esEntPermitErrDao.updateObjectBySql("delete from 表名");
            List<EsEntPermitErr> list = new ArrayList<EsEntPermitErr>();
            Connection con = null;// 创建一个数据库连接
            PreparedStatement pre = null;// 创建预编译语句对象,一般都是用这个而不用Statement
            ResultSet result = null;// 创建一个结果集对象
            try
            {
                Class.forName("oracle.jdbc.driver.OracleDriver");// 加载Oracle驱动程序
                System.out.println("开始尝试连接数据库!");
    //            String url = "jdbc:oracle:thin:@192.168.0.22:1521:orcl";// 127.0.0.1是本机地址,XE是精简版Oracle的默认数据库名
    //            String user = "用户名";// 用户名,系统默认的账户名
    //            String password = "密码";// 你安装时选设置的密码
                con = DriverManager.getConnection(url, user, password);// 获取连接
                System.out.println("连接成功!");
                pre = con.prepareStatement("SELECT * FROM 表名 );// 实例化预编译语句
                result = pre.executeQuery();// 执行查询,注意括号中不需要再加参数
                while (result.next()) {
                    // 当结果集不为空时
                    EsEntPermitErr esEntPermitErr = new EsEntPermitErr();//创建一个新对象,赋值给用户
                        
                        esEntPermitErr.setXkxdrmc(result.getString("XK_XDR_MC"));
                        esEntPermitErr.setXkxdrshxym(result.getString("XK_XDR_SHXYM"));
                        esEntPermitErr.setXkxdrgszc(result.getString("XK_XDR_GSZC"));
                        esEntPermitErr.setXkxdrzzjg(result.getString("XK_XDR_ZZJG"));
                        esEntPermitErr.setXkxdrswdj(result.getString("XK_XDR_SWDJ"));
                        esEntPermitErr.setXkfrdb(result.getString("XK_FRDB"));
                        esEntPermitErr.setXkwsh(result.getString("XK_WSH"));
                        esEntPermitErr.setXknr(result.getString("XK_NR"));
                        esEntPermitErr.setXkjdrq(result.getDate("XK_JDRQ"));
                        esEntPermitErr.setXkxkjg(result.getString("XK_XKJG"));
                        
                        list.add(esEntPermitErr);
                }
                    for(EsEntPermitErr lis:list) {
                        this.save(lis);
                }
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }
            finally
            {
                try
                {
                    // 逐一将上面的几个对象关闭,因为不关闭的话会影响性能、并且占用资源
                    // 注意关闭的顺序,最后使用的最先关闭
                    if (result != null)
                        result.close();
                    if (pre != null)
                        pre.close();
                    if (con != null)
                        con.close();
                    System.out.println("数据库连接已关闭!");
                }
                catch (Exception e)
                {
                    e.printStackTrace();
                }
            }
        }
  • 相关阅读:
    iptables之NAT端口转发设置
    Windows server 2008 R2远程桌面3389端口号修改
    Nginx启动错误:error while loading shared libraries: libpcre.so.1
    sp_change_users_login 'Update_One', '用户名', '登录名';
    Sqlserver 数据库定时自动备份
    ES DSL 基础查询语法学习笔记
    kafka命令使用
    kafka集群中常见错误的解决方法:kafka.common.KafkaException: Should not set log end offset on partition
    快速排序法(双冒泡排序法)
    运算符
  • 原文地址:https://www.cnblogs.com/yanchaohui/p/10736037.html
Copyright © 2011-2022 走看看