连接到SQL数据库 connecting-to-sql-databases
访问外部SQL数据库,以便CQ应用程序可以与数据交互:
捆绑JDBC数据库驱动程序 bundling-the-jdbc-database-driver
例如,一些数据库供应商在OSGi包中提供JDBC驱动程序 MySQL. 如果数据库的JDBC驱动程序不可用作OSGi包,请获取该驱动程序JAR并将其封装在OSGi包中。 包必须导出与数据库服务器交互所需的包。 包还必须导入其引用的包。
以下示例使用 用于Maven的包插件 将HSQLDB驱动程序封装在OSGi包中。 POM会指示该插件嵌入标识为依赖项的hsqldb.jar文件。 所有org.hsqldb包都将导出。
该插件会自动确定要导入的包,并将其列在包的MANIFEST.MF文件中。 如果CQ服务器上没有任何包,则在安装时将不会启动包。 可能的解决方案如下:
-
在POM中指示包是可选的。 当JDBC连接实际上不需要包成员时,请使用此解决方案。 使用Import-Package元素指示可选包,如以下示例中所示:
<Import-Package>org.jboss.*;resolution:=optional,*</Import-Package>
-
将包含包的JAR文件包装在导出包的OSGi包中,并部署包。 如果在代码执行期间需要包成员,请使用此解决方案。
了解源代码可让您确定要使用的解决方案。 您还可以尝试使用任一解决方案并执行测试以验证解决方案。
捆绑hsqldb.jar的POM pom-that-bundles-hsqldb-jar
<project xmlns="https://maven.apache.org/POM/4.0.0"
xmlns:xsi="https://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="https://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.adobe.example.myapp</groupId>
<artifactId>hsqldb-jdbc-driver-bundle</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>wrapper-bundle-hsqldb-driver</name>
<url>www.adobe.com</url>
<description>Exports the HSQL JDBC driver</description>
<packaging>bundle</packaging>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<build>
<plugins>
<plugin>
<groupId>org.apache.felix</groupId>
<artifactId>maven-bundle-plugin</artifactId>
<version>1.4.3</version>
<extensions>true</extensions>
<configuration>
<instructions>
<Embed-Dependency>*</Embed-Dependency>
<_exportcontents>org.hsqldb.*</_exportcontents>
</instructions>
</configuration>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>hsqldb</groupId>
<artifactId>hsqldb</artifactId>
<version>2.2.9</version>
</dependency>
</dependencies>
</project>
以下链接可打开一些常用数据库产品的下载页面:
配置JDBC连接池服务 configuring-the-jdbc-connection-pool-service
为JDBC连接池服务添加配置,该服务使用JDBC驱动程序创建数据源对象。 您的应用程序代码使用此服务获取对象并连接到数据库。
JDBC连接池( com.day.commons.datasource.jdbcpool.JdbcPoolService
)是工厂服务。 如果您需要使用不同属性(例如只读或读/写访问)的连接,请创建多个配置。
使用CQ时,可通过多种方法来管理此类服务的配置设置;请参阅 配置OSGi 以了解完整详细信息。
以下属性可用于配置池化连接服务。 属性名称会按在Web控制台中显示的方式列出。 对应的 sling:OsgiConfig
节点显示在圆括号中。 HSQLDB服务器和别名为 mydb
:
-
JDBC驱动程序类(
jdbc.driver.class
):用于实现java.sql.Driver接口的Java类,例如org.hsqldb.jdbc.JDBCDriver
. 数据类型为String
. -
JDBC连接URI(
jdbc.connection.uri
):用于创建连接的数据库的URL,例如jdbc:hsqldb:hsql//10.36.79.223:9001/mydb
. URL的格式必须有效,才能与java.sql.DriverManager类的getConnection方法一起使用。 数据类型为String
. -
用户名(
jdbc.username
):用于通过数据库服务器进行身份验证的用户名。 数据类型为String
. -
密码(
jdbc.password
):用于用户身份验证的密码。 数据类型为String
. -
验证查询(
jdbc.validation.query
):用于验证连接是否成功的SQL语句,例如select 1 from INFORMATION_SCHEMA.SYSTEM_USERS
. 数据类型为String
. -
默认为只读(default.readonly):如果希望连接提供只读访问权限,请选择此选项。 数据类型为
Boolean
. -
默认情况下自动提交(
default.autocommit
):选择此选项可为发送到数据库的每个SQL命令创建单独的事务,并且每个事务都会自动提交。 在代码中显式提交事务时,请勿选择此选项。 数据类型为Boolean
. -
池大小(
pool.size
):要向数据库提供的同时连接数。 数据类型为Long
. -
池等待(
pool.max.wait.msec
):连接请求超时前的时间。 数据类型为Long
. -
数据源名称(
datasource.name
):此数据源的名称。 数据类型为String
. -
其他服务属性(
datasource.svc.properties
):要附加到连接URL的一组名称/值对。 数据类型为String[]
.
JDBC连接池服务是工厂。 因此,如果您使用 sling:OsgiConfig
节点要配置连接服务,节点的名称必须包括出厂服务PID,后跟 -alias
. 对于该PID的所有配置节点,您使用的别名必须是唯一的。 节点名称的示例为 com.day.commons.datasource.jdbcpool.JdbcPoolService-myhsqldbpool
.
连接到数据库 connecting-to-the-database
在您的Java代码中,使用DataSourcePool服务获取 javax.sql.DataSource
对象。 DataSourcePool服务提供 getDataSource
返回 DataSource
对象。 将数据源名称的值(或 datasource.name
)为JDBC连接池配置指定的属性。
以下示例JSP代码获取hsqldbds数据源的一个实例,执行简单的SQL查询,并显示返回的结果数。
执行数据库查找的JSP jsp-that-performs-a-database-lookup
<%@include file="/libs/foundation/global.jsp"%><%
%><%@page session="false"%><%
%><%@ page import="com.day.commons.datasource.poolservice.DataSourcePool" %><%
%><%@ page import="javax.sql.DataSource" %><%
%><%@ page import="java.sql.Connection" %><%
%><%@ page import="java.sql.SQLException" %><%
%><%@ page import="java.sql.Statement" %><%
%><%@ page import="java.sql.ResultSet"%><%
%><html>
<cq:include script="head.jsp"/>
<body>
<%DataSourcePool dspService = sling.getService(DataSourcePool.class);
try {
DataSource ds = (DataSource) dspService.getDataSource("hsqldbds");
if(ds != null) {
%><p>Obtained the datasource!</p><%
%><%final Connection connection = ds.getConnection();
final Statement statement = connection.createStatement();
final ResultSet resultSet = statement.executeQuery("SELECT * from INFORMATION_SCHEMA.SYSTEM_USERS");
int r=0;
while(resultSet.next()){
r=r+1;
}
resultSet.close();
%><p>Number of results: <%=r%></p><%
}
}catch (Exception e) {
%><p>error! <%=e.getMessage()%></p><%
}
%></body>
</html>