java 读取mysql中数据 并取出
2015-09-16 11:46
537 查看
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); }
相关文章推荐
- Java中泛型数组的使用
- java io详解
- java基础-ArrayList
- 当eclipse导入工程时报"The builder launch configuration could not be found"错误时的解决方法
- Eclipse调试进入JDK源码
- java 图片上写文字
- java中两个for循环的区别
- Java多线程---main与子线程 start与run
- java socket编程
- java 反编译 行号对齐 decompiler如何去掉行号
- spring aop术语
- Android无法导入下载好的项目(和Eclipse中已经存在的项目命名一样导致冲突)解决办法
- eclipse+Jboss配置远程调试
- Java泛型中的通配符的使用
- Eclipse快捷键
- java设计模式系列--工厂模式
- Google Java编程风格指南
- java.lang.IndexOutOfBoundsException: Invalid index 0, size is 0错误解析
- java.util.vector中的vector的详细用法
- JAVA List 移除元素