zoukankan      html  css  js  c++  java
  • java 读取mysql中数据 并取出

    public static String url = null;
        public static String username = null;
        public static String password = null;
        public static Connection conn;
        public static Statement stmt;
        public static ResultSet rs;
        public static String fileName = null;
        public static List lists = new ArrayList();
    
        public static String PATH = "/dbconfig.properties";
        private static Properties properties;
        static {
            try {
                InputStream is = DBlUtils.class.getResourceAsStream(PATH);
                properties = new Properties();
                properties.load(is);
                url = properties.getProperty("jdbc.url");
                username = properties.getProperty("jdbc.username");
                password = properties.getProperty("jdbc.password");
                fileName = properties.getProperty("fileName");
                System.out.println("fileName:" + fileName);
                if (is != null)
                    is.close();
            } catch (IOException e) {
    
                e.printStackTrace();
            }
    
        }
    
        public void closeConnection(Connection conn) {
    
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
    
    
    /**
         * 查询mysql 数据库数据,并获得内容
         * 
         * @param sql
         */
        public static void queryDatas(String sql) {
    
            try {
                conn = DriverManager.getConnection(url, username, password);
                conn.setAutoCommit(false);
                stmt = conn.prepareStatement("load data local infile '' " + "into table loadtest fields terminated by ','");
                StringBuilder sb = new StringBuilder();
                InputStream is = new ByteArrayInputStream(sb.toString().getBytes());
                ((com.mysql.jdbc.Statement) stmt).setLocalInfileInputStream(is);
                ResultSet rs = stmt.executeQuery(sql);
                ResultSetMetaData rsmd = rs.getMetaData();
                int columnCount = rsmd.getColumnCount();
                // 输出列名
                for (int i = 1; i <= columnCount; i++) {
                    System.out.print(rsmd.getColumnName(i));
                    System.out.print("(" + rsmd.getColumnTypeName(i) + ")");
                    System.out.print(" | ");
                }
                System.out.println();
                // 输出数据
                while (rs.next()) {
                    for (int i = 1; i <= columnCount; i++) {
                        System.out.print(rs.getString(i) + " | ");
                    }
                    System.out.println();
                }
    
                // conn.commit();
            } catch (SQLException e) {
                e.printStackTrace();
            }
    
        }

    public static void main(String[] args) {

            String sql = "select * from tablename";
            queryDatas(sql);

        }
  • 相关阅读:
    脚本添加crontab任务
    docker mysql8 注意
    使用 logrotate 清理日志
    腾讯云cos对象在线显示
    快速部署私人git服务--基于docker化Gogs
    grep 使用
    vsftpd 新增虚拟用户
    unistd.h
    ffmpeg
    H264视频压缩算法
  • 原文地址:https://www.cnblogs.com/zhanggl/p/4812839.html
Copyright © 2011-2022 走看看