MySQL---数据库从入门走向大神系列(十一)-Java获取数据库/结果集的元信息、将数据表写入excel表格
【摘要】 数据库的元信息：
首先介绍一下数据库的元信息(元数据)：
元数据(Metadata)是关于数据的数据。
元数据是描述数据仓库内数据的结构和建立方法的数据。
存储的数据是什么类型,什么驱动等等，这些描述数据的数据，就是元数据！
准备：
package cn.hncu.pool3;
import java.lang.reflect.InvocationHand...
数据库的元信息：
首先介绍一下数据库的元信息(元数据)：
元数据(Metadata)是关于数据的数据。
元数据是描述数据仓库内数据的结构和建立方法的数据。
存储的数据是什么类型,什么驱动等等，这些描述数据的数据，就是元数据！
准备：
package cn.hncu.pool3;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
public class ConnsUtil { private static List<Connection> pool = new ArrayList<Connection>(); private static final int NUM=3; static{ try { //读取配置文件 Properties p = new Properties(); p.load(ConnsUtil.class.getClassLoader().getResourceAsStream("jdbc.properties")); String driver = p.getProperty("driver"); String url = p.getProperty("url"); String user = p.getProperty("username"); String password = p.getProperty("password"); Class.forName(driver); for(int i=0;i<NUM;i++){ final Connection conn = DriverManager.getConnection(url, user, password); //只需要改这里就行了！ //使用动态代理代理conn对象，实现对close方法的拦截 Object obj = Proxy.newProxyInstance( ConnsUtil.class.getClassLoader(), conn.getClass().getInterfaces(), new InvocationHandler() { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { if(method.getName().equalsIgnoreCase("close") && (args==null || args.length==0)){ pool.add((Connection)proxy); return null; }else{ return method.invoke(conn, args); } } }); pool.add((Connection)obj); } } catch (Exception e) { e.printStackTrace(); } } public static synchronized Connection getConn() throws Exception{ if(pool.size()<=0){ Thread.sleep(100); return getConn(); } return pool.remove(0); }
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
使用java.sql 中的接口 DatabaseMetaData就可以实现：
演示类：
package cn.hncu.meta;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import org.junit.Test;
import cn.hncu.pool3.ConnsUtil;
public class MetaDataDemo { // ※元信息1：通过con获得DatabaseMetaData(数据库元信息)---数据库连接信息、数据库名、表名 @Test public void databaseMetadataDemo() throws Exception { // 获取数据库的元信息 Connection con = ConnsUtil.getConn(); // ********关键 DatabaseMetaData dm = con.getMetaData(); // 获取此 JDBC 驱动程序的名称。 System.out.println(dm.getDriverName()); // 获取此 JDBC 驱动程序的主版本号。 System.out.println(dm.getDriverMajorVersion()); // 获取在此数据库中在同一时间内可处于开放状态的最大活动语句数。--返回结果为零意味着没有限制或限制是未知的 System.out.println(dm.getMaxStatements()); // 获取此驱动程序的主 JDBC 版本号。 System.out.println(dm.getJDBCMajorVersion()); // 还有很多方法，可以去API自己查 System.out.println("========================="); // 下面是动态获取数据库名 ResultSet rs = dm.getCatalogs(); // 相当于执行:show databases; while (rs.next()) { System.out.println(rs.getString(1)); // 进行元数据操作获得数据库名 } // 知道数据库的名字 con.createStatement().execute("use hncu"); // 动态获取表名 // 可以把参数null写成“%o%”进行模糊查询 ResultSet rs2 = dm.getTables("hncu", "hncu", null, new String[] { "TABLE" }); while (rs2.next()) { System.out.println(rs2.getString("TABLE_NAME")); // 进行元数据操作，获得表名 } } // ※元信息2：通过rs获得ResultSetMetaData(结果集元信息)---表头(每个字段名)、表格行数、列数 // 在知道数据库名和表名的情况下，把表头和表内容都查询出来。 @Test // 站在结果集的高度---也就是表格 public void resultSetMetaDataDemo() throws Exception{ Connection con1 = ConnsUtil.getConn(); Statement st = con1.createStatement(); //如果是跨库查询,sql:“数据库名.表名”----select * from 数据库.表名 String sql = "select * from stud";//我们的连接是hncu数据库的，访问hncu数据库直接写表名就可以 ResultSet rs = st.executeQuery(sql); //结果集的元信息 ResultSetMetaData rsmd = rs.getMetaData(); int columns = rsmd.getColumnCount(); //获得表格的列数 //输出整个数据表(包括表头) //表头 for(int i=0;i<columns;i++){ String columnName = rsmd.getColumnName(i+1); System.out.print(columnName+"\t"); } System.out.println(); System.out.println("------------------------"); //表内容 while(rs.next()){ for(int i=0;i<columns;i++){ String content = rs.getString(i+1); System.out.print(content+"\t"); } System.out.println(); } }
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
- 72
- 73
- 74
- 75
- 76
- 77
- 78
- 79
- 80
- 81
- 82
- 83
- 84
- 85
- 86
- 87
- 88
- 89
- 90
- 91
- 92
getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types)方法的参数解析：
catalog -类别名称：
它必须与存储在数据库中的类别名称匹配；该参数为 "" 表示获取没有类别的那些描述；为 null则表示该类别名称不应该用于缩小搜索范围
schemaPattern - 模式名称的模式：
它必须与存储在数据库中的模式名称匹配；该参数为"" 表示获取没有模式的那些描述；为 null 则表示该模式名称不应该用于缩小搜索范围
tableNamePattern -表名称模式：
它必须与存储在数据库中的表名称匹配
types - 要包括的表类型所组成的列表，必须取自从 getTableTypes()返回的表类型列表；null 表示返回所有类型
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
这样就遍历出来了。
将数据表写入excel表格
首先需要准备一个apache的Jar：
链接：
https://github.com/chenhaoxiang/Java
先创建一个简单的数据：
package cn.hncu.meta;
import java.io.FileOutputStream;
import java.io.IOException;
import org.apache.poi.hssf.usermodel.HSSFCell;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.junit.Test;
public class ExportXls { @Test public void mkXlsDemo() throws IOException{ //需求: 创建一个工作薄:a.xls, 工作表: 表1, 第4行第5列的单元格中写入文字:湖南城院 HSSFWorkbook book = new HSSFWorkbook(); HSSFSheet sheet = book.createSheet("表一"); HSSFRow row4 = sheet.createRow(3);//行数为下标加1 //该方法的参数值是从0开始的---真正的表格中的序号是从1开始标示 HSSFCell cell5 = row4.createCell(4); FileOutputStream fout = new FileOutputStream("a.xls"); book.write(fout); }
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
将数据库的所有表格数据遍历写入至excel表格
@Test public void exportTest() throws Exception{ //这里我们只遍历存储hncu数据库 String dbName="hncu"; String xlsFileName="b.xls"; exportDb2Xls(dbName,xlsFileName); } public void exportDb2Xls(String dbName,String xlsFileName) throws Exception{ HSSFWorkbook book = new HSSFWorkbook(); Connection con = ConnsUtil.getConn(); DatabaseMetaData dm = con.getMetaData(); //写代码时，尽量避免结果集套接操作，在一个结果集操作的内部进行其它结果集操作 //如果有事务，一个结果集的回退或提交可能会波及另一个 ResultSet rs = dm.getTables(dbName, dbName, null, new String[]{"TABLE"}); List<String> tables = new ArrayList<String>(); while(rs.next()){ String tableName = rs.getString("TABLE_NAME"); tables.add(tableName); } Statement st = con.createStatement(); for(String tableName: tables){ //创建一个表名为tableName的表 HSSFSheet sheet = book.createSheet(tableName); //这样写，可以跨数据库访问 String sql ="select * from "+dbName+"."+tableName; rs = st.executeQuery(sql); //把表头遍历出来且写到xls文件中 HSSFRow row = sheet.createRow(0);//表头行 ResultSetMetaData rsmd = rs.getMetaData(); int colNum = rsmd.getColumnCount(); for(int i=0;i<colNum;i++){ HSSFCell cell = row.createCell(i); String colName = rsmd.getColumnName(i+1); cell.setCellValue(colName); } //所有数据行 int idx = 1; while(rs.next()){ row = sheet.createRow(idx++); for(int i=0;i<colNum;i++){ HSSFCell cell = row.createCell(i); cell.setCellValue( rs.getString(i+1) ); } } } FileOutputStream fout = new FileOutputStream(xlsFileName); book.write(fout); }
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
文章来源: chenhx.blog.csdn.net，作者：谙忆，版权归原作者所有，如需转载，请联系作者。
原文链接：chenhx.blog.csdn.net/article/details/52191622
【版权声明】本文为华为云社区用户转载文章，如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱：
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论（0）