jdbc in postgres

try {
            Class.forName("org.postgresql.Driver").newInstance();
            String url = "jdbc:postgresql://localhost:5432/erp";
            String user = "xx";
            String pwd = "xx";
            Connection conn = DriverManager.getConnection(url, user, pwd);
            Statement st = conn.createStatement();
            ResultSet rs = st.executeQuery("SELECT * FROM goods_picture where md5 is null");
            List<String> paths = new ArrayList<String>();
            int i = 0;
            while (rs.next()) {
                i++;
                LOGGER.debug(rs.getString(1));//id
                LOGGER.debug(rs.getString(2));//goodsid
                LOGGER.debug(rs.getString(3));//seqno
                LOGGER.debug(rs.getString(4));//picturetypeid
                LOGGER.debug(rs.getString(5));//title
                LOGGER.debug(rs.getString(6));//path
                paths.add(rs.getString(6));
                LOGGER.debug(rs.getString(7));//companyid
                LOGGER.debug(rs.getString(8));
                LOGGER.debug(rs.getString(9));
                LOGGER.debug(rs.getString(10));
            }
            LOGGER.debug("total:"+i);
            rs.close();
            st.close();

            //批量更新
                conn.setAutoCommit(false);
                Statement stmt =conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
                for(int x = 0; x < paths.size();x++){
                    String path = paths.get(x);
                    String md5 = ImageMigrator.readAndUpload(null,path);
                    if(md5!=null){
                        stmt.addBatch("update goods_picture set md5=‘"+md5+"‘ where path=‘"+path+"‘");
                    }
                }
                stmt.executeBatch();
                conn.commit();
                stmt.close();
                conn.close();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
时间: 2024-11-21 01:27:37

jdbc in postgres的相关文章

PostgreSQL参数配置

jdbc.driverClassName=org.postgresql.Driver jdbc.url=jdbc:postgresql://localhost:5432/luzhichao jdbc.username=postgres jdbc.password=lu123456 #<!--初始化连接--> dataSource.initialSize=10 #<!--最大空闲连接--> dataSource.maxIdle=20 #<!--最小空闲连接--> data

JBoss EAP 为应用项目配置PostgreSQL数据源

一.前言 客户在计划将业务向云平台迁移,这些天也在测试将数据库由Oracle替换为开源的PostgrSQL.为什么选PostgreSQL?因为这是对应用程序代码修改最小的方案,没有之一! PostgreSQL数据库的简要信息为:服务器loacalhost,端口5432,数据库projadm,用户名/密码:projadm/proj2013. 开始前,在https://jdbc.postgresql.org/download.html下载与JBoss版本和JDK版本匹配的JDBC驱动包,存放某目录(

nakadi 一款基于kafka 的http event broker

nakadi 是zalando 开源的一款基于kafka 的event broker ,我们可以方便的使用http 协议进行操作 支持一些特性: stream 操作,我们可以流的方式订阅event event 支持基于json schema 我们可以对于event 进行数据校验,方便的schema 注册 支持oauth .event type 的安全认证,同时也支持黑名单用户以及应用授权 比较全的监控集成 环境准备 docker-compose 文件 说明使用pg 存储基本的元数据,此项目集成了

Kubernetes 多container组成的Pod

在上一篇文章中我们使用kubectl run的方式来创建一个pod,但是pod中只含有一个container.我们知道pod中是可以包含多个container的,在这篇文章中,将会通过创建一个由sonarqube+postgresql组成的pod来演示在kubernetes中如何使用多个container来组成一个pod. 构成说明 演示程序使用下列的集群构成. No type IP OS 1 master 192.168.32.131 CENTOS7.2 2 etcd 192.168.32.1

Canal——增量同步MySQL数据到ES

1.准备 1.1.组件 JDK:1.8版本及以上: ElasticSearch:6.x版本,目前貌似不支持7.x版本:     Canal.deployer:1.1.4 Canal.Adapter:1.1.4 1.1.配置 需要先开启MySQL的 binlog 写入功能,配置 binlog-format 为 ROW 模式 找到my.cnf文件,我的目录是/etc/my.cnf,添加以下配置: log-bin=mysql-bin # 开启 binlog binlog-format=ROW # 选择

aceql-http docker 试用

以前有介绍过aceql-http 一个不错的database rest http 暴露,充分利用了tomcat 的好多特性,以下是基于docker 运行的学习 环境准备 dockerfile FROM dalongrong/openjdk11:stretch-jvm-tools LABEL AUTHOR="rongfengliang" LABEL EMAIL="[email protected]" ENV VERSION=4.0 ENV ACEQL_HTTP_HOS

pgAdmin的使用,PostgreSQL的sql基本语法,JDBC连接到postgresql

简介 我们可以通过一些图形界面的管理程序,例如pgadmin来管理postgresql数据库,通过可视化或者命令行的方式的创建新的对象,删除和编辑现有的对象(例如目录,模式,表等对象),再通过JDBC或者ODBC来访问它们. 界面操作: 要打开一个到服务的连接,在树中选择所需的服务,并双击它,或使用“工具”菜单上的连接即可.在主窗口中,显示数据库的结构.您可以创建新的对象,删除和编辑现有的对象,如果你使用的是当前连接到数据库用户的权限,在主窗口的左侧显示所有服务器,以及它们所包含的对象树. 右上

Postgres数据库基本介绍

最近一直在做一个和PostgreSQL数据库相关的项目,把自己在这个过程中学习的知识记录下来.关于PostgreSQL数据库网上已经有太多的相关介绍了,为了博文的系统性还是先看一下维基百科对PostgreSQL数据库的介绍吧. PostgreSQL是自由的对象-关系型数据库服务器(数据库管理系统),在灵活的BSD-风格许可证下发行.它在其他开放源代码数据库系统(比如MySQL和Firebird),和专有系统比如Oracle.Sybase.IBM的DB2和Microsoft SQL Server之

Postgres XL FAQ

Q. What does XL stand for? XL is short for eXtensible Lattice. It also connotes an extra large version of PostgreSQL, in this case across multiple systems. Q. Is this a "NoSQL" solution? No, Postgres-XL supports traditional SQL, strongly conform