Spring 利用 Mongo 通过 JPA 实现

我对 Spring 框架相当陌生，并且在设置我当前正在处理的项目时遇到了一些问题。我需要能够连接到两个不同的数据库，一个是 MongoDB，另一个是 MSSQL。我正在使用 JPA 连接到 MSSQL。

我遇到的问题是，当我希望它调用 MSSQL 时，它似乎试图调用 Mongo 数据库，而我不太确定如何告诉它要读取什么。我看过建议使用的帖子@Qualifier注释将其定向到正确的实现，但我认为这不适用于我的情况。

@RestController
@RequestMapping("/software")
public class SoftwareEndpoint {



    @Autowired
    SoftwareRepository repo;    


    /**********************************************************************************
    ********************************MSSQL calls****************************************
    ***********************************************************************************/
    @RequestMapping(value="/all",method=RequestMethod.GET,produces=MediaType.APPLICATION_JSON)
    String getAllSoftware(){

        System.out.println("Here1");
        List<Software> allSoftware = (List<Software>) repo.findAll();
        System.out.println("Here2");
        //rest of method and class

上面显示了我的控制器类的片段，其中包含我的 SoftwareRepository 的实例。我还在数据库调用之前和之后打印到输出流。

输出流仅显示“Here1”，继续打印出这一行：

2016-10-04 07:35:39.810  INFO 4236 --- [nio-8080-exec-2] org.mongodb.driver.cluster               : No server chosen by ReadPreferenceServerSelector{readPreference=primary} from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, all=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING, exception={com.mongodb.MongoSocketOpenException: Exception opening socket}, caused by {java.net.ConnectException: Connection refused: connect}}]}. Waiting for 30000 ms before timing out

然后在超时时抛出异常。

我没有本地运行的 mongo 实例，但是在部署应用程序的地方会有，但我不认为这是问题，因为在到达该端点时，它不应该调用 Mongo数据库，它应该尝试连接 MSSQL。

TLDR：如何指定 Spring 用于特定存储库或数据库调用的数据库实现？

spring中可以根据context中的配置连接不同的数据库。

以下代码用于连接 MySql 和 Mongo DB。如果您有 JDBC，则可以用 MSSQL 替代 MySql。查看http://jdbforms.sourceforge.net/UsersGuide/html/ch20s02.html http://jdbforms.sourceforge.net/UsersGuide/html/ch20s02.html了解 JDBC 连接的属性的含义。

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg ref="mySqldataSource" /> <!-- Change the datasource to MSSQL-->
    </bean>

    <bean id="mySqldataSource" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="removeAbandoned">
            <value>true</value>
        </property>
        <property name="removeAbandonedTimeout">
            <value>30</value>
        </property>
        <property name="driverClassName">
            <value>MSSQL_DRIVER_CLASS_NAME</value>
        </property>
        <property name="url">
            <value>MSSQL_DATABASE_URL</value>
        </property>
        <property name="username">
            <value>MSSQL_DB_USER_NAME</value>
        </property>
        <property name="password">
            <value>MSSQL_DB_PASSWORD</value>
        </property>
        <property name="maxIdle"> 
            <value>10</value>
        </property>
        <property name="maxActive"> 
            <value>10</value>
        </property>
        <property name="maxWait">
            <value>100000</value>
        </property>
        <property name="testOnBorrow">
            <value>false</value>
        </property>
        <property name="testWhileIdle">
            <value>false</value>
        </property>
        <property name="timeBetweenEvictionRunsMillis">
            <value>60000</value>
        </property>
        <property name="minEvictableIdleTimeMillis">
            <value>60000</value>
        </property>
        <property name="numTestsPerEvictionRun">
            <value>1</value>
        </property>
        <property name="defaultTransactionIsolation" value="1" />
        <property name="poolPreparedStatements" value="true" />
        <property name="maxOpenPreparedStatements" value="1" />
    </bean>

    <bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"></bean>

下面是连接mongodb

    <mongo:db-factory dbname="mongoDbName" host="mongoServer" port="mongoPort"/>


    <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
        <constructor-arg name="mongoDbFactory" ref="mongoDbFactory" />
    </bean>
    <mongo:repositories base-package="com.test.repoPackage"/> <!-- Package containing the mongo repository interfaces -->

现在你可以使用spring提供的存储库了。

EDIT 1:假设配置名称是 springConfig.properties。在上面 mongo:db-factory 中的属性 dbname、host 和 port 的示例中，您可能希望在 springConfig.properties 中配置这些值。所以让我们在下面命名它们：

mongoServer = xxx.xx.xxx.xxx
mongoPort = 27017
mongoDb = testDb

现在需要修改上下文文件以导入 springConfig.properties。这是在上下文文件中按如下方式完成的：

<bean id="propertyConfigurer"
        class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" >
        <property name="locations" >
            <list>              
                <value>classpath:/log4j.properties</value>
                <value>classpath:/springConfig.properties</value>
            </list>
        </property>
    </bean>

bean mongo:db-factory 现在看起来像：

<mongo:db-factory dbname="${mongoDb}" host="${mongoServer}" port="${mongoPort}"/>

请注意，配置中的“键”（数据库名称、主机和端口）在 ${} 中表示。这将替换为键配置中的值。