Yay ile 2 veya daha fazla veritabanı nasıl kullanılır?

İlkbahar MVC'yi çalıştıran bir uygulamam var.Yay ile 2 veya daha fazla veritabanı nasıl kullanılır?

Uygulamamdaki 2 farklı veritabanına erişmek için ihtiyacım var (biri PostgreSQL, diğeri ise bir MySQL veritabanıdır).

Bunu yalnızca ek açıklamaları veya application.properties dosyasını kullanarak nasıl yapılandırabilirim?

Saygılarımızla.

2015-05-21 Marcio Andrey Oliveira

@duffymo: öncelikle doğrultusunda sizi teşekkür ediyoruz cevap verme zamanı. Kolay olduğuna inanıyorum ama bunu yapan bir belge/numune bulamadım. Bazı dokümanları paylaşabilir misiniz? Saygılarımızla. –

@MarcioAndreyOliveira [buradan] (http://www.codingpedia.org/ama/how-to-setup-multiple-data-sources-with-spring-and-jpa/) ya da coderanch] (http://www.coderanch.com/t/558790/Spring/Spring-JPA-Hibernate-multiple-Database). Bence bu sana yardım edebilir. – calazans

Application.properties'den bahsetmenizin nedeni, Spring Boot hakkında sorduğunuzu sanıyor - lütfen etiketleri güncelleyin, soruyu oldukça fazla değiştirir. – kryger

yardımcı olur ben yardımcı olur umarım Spring-Boot üzerinde multiple Database/datasource sahibi olmak için örnek kod umut!

application.properties

spring.ds_items.driverClassName=org.postgresql.Driver 
spring.ds_items.url=jdbc:postgresql://srv0/test 
spring.ds_items.username=test0 
spring.ds_items.password=test0 


spring.ds_users.driverClassName=org.postgresql.Driver 
spring.ds_users.url=jdbc:postgresql://srv1/test 
spring.ds_users.username=test1 
spring.ds_users.password=test1

DatabaseItemsConfig.java

package sb; 

import org.springframework.boot.autoconfigure.jdbc.TomcatDataSourceConfiguration; 
import org.springframework.boot.context.properties.ConfigurationProperties; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.jdbc.core.JdbcTemplate; 

import javax.sql.DataSource; 

@Configuration 
@ConfigurationProperties(name = "spring.ds_items") 
public class DatabaseItemsConfig extends TomcatDataSourceConfiguration { 

    @Bean(name = "dsItems") 
    public DataSource dataSource() { 
     return super.dataSource(); 
    } 

    @Bean(name = "jdbcItems") 
    public JdbcTemplate jdbcTemplate(DataSource dsItems) { 
     return new JdbcTemplate(dsItems); 
    } 
}

DatabaseUsersConfig.java

package sb; 

import org.springframework.boot.autoconfigure.jdbc.TomcatDataSourceConfiguration; 
import org.springframework.boot.context.properties.ConfigurationProperties; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.jdbc.core.JdbcTemplate; 

import javax.sql.DataSource; 

@Configuration 
@ConfigurationProperties(name = "spring.ds_users") 
public class DatabaseUsersConfig extends TomcatDataSourceConfiguration { 

    @Bean(name = "dsUsers") 
    public DataSource dataSource() { 
     return super.dataSource(); 
    } 

    @Bean(name = "jdbcUsers") 
    public JdbcTemplate jdbcTemplate(DataSource dsUsers) { 
     return new JdbcTemplate(dsUsers); 
    } 

}

ItemRepository.java

package sb; 

import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Qualifier; 
import org.springframework.jdbc.core.JdbcTemplate; 
import org.springframework.jdbc.core.RowMapper; 
import org.springframework.stereotype.Repository; 

import java.sql.ResultSet; 
import java.sql.SQLException; 

@Repository 
public class ItemRepository { 
    protected final Logger log = LoggerFactory.getLogger(getClass()); 

    @Autowired 
    @Qualifier("jdbcItems") 
    protected JdbcTemplate jdbc; 

    public Item getItem(long id) { 
     return jdbc.queryForObject("SELECT * FROM sb_item WHERE id=?", itemMapper, id); 
    } 

    private static final RowMapper<Item> itemMapper = new RowMapper<Item>() { 
     public Item mapRow(ResultSet rs, int rowNum) throws SQLException { 
      Item item = new Item(rs.getLong("id"), rs.getString("title")); 
      item.price = rs.getDouble("id"); 
      return item; 
     } 
    }; 
}

UserRepository.java

package sb; 

import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Qualifier; 
import org.springframework.jdbc.core.JdbcTemplate; 
import org.springframework.jdbc.core.RowMapper; 
import org.springframework.stereotype.Repository; 

import java.sql.ResultSet; 
import java.sql.SQLException; 

@Repository 
public class UserRepository { 
    protected final Logger log = LoggerFactory.getLogger(getClass()); 

    @Autowired 
    @Qualifier("jdbcUsers") 
    protected JdbcTemplate jdbc; 

    public User getUser(long id) { 
     return jdbc.queryForObject("SELECT * FROM sb_user WHERE id=?", userMapper, id); 
    } 

    private static final RowMapper<User> userMapper = new RowMapper<User>() { 
     public User mapRow(ResultSet rs, int rowNum) throws SQLException { 
      User user = new User(rs.getLong("id"), rs.getString("name")); 
      user.alias = rs.getString("alias"); 
      return user; 
     } 
    }; 
}

Controller.java

package sb; 

import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.web.bind.annotation.RequestMapping; 
import org.springframework.web.bind.annotation.RequestParam; 
import org.springframework.web.bind.annotation.RestController; 

@RestController 
public class Controller { 
    protected final Logger log = LoggerFactory.getLogger(getClass()); 

    @Autowired 
    private UserRepository users; 

    @Autowired 
    private ItemRepository items; 

    @RequestMapping("test") 
    public String test() { 
     log.info("Test"); 
     return "OK"; 
    } 

    @RequestMapping("user") 
    public User getUser(@RequestParam("id") long id) { 
     log.info("Get user"); 
     return users.getUser(id); 
    } 

    @RequestMapping("item") 
    public Item getItem(@RequestParam("id") long id) { 
     log.info("Get item"); 
     return items.getItem(id); 
    } 

}

Application.java

package sb; 

import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.EnableAutoConfiguration; 
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; 
import org.springframework.context.annotation.ComponentScan; 
import org.springframework.context.annotation.Configuration; 

@EnableAutoConfiguration(exclude = DataSourceAutoConfiguration.class) 
@Configuration 
@ComponentScan(basePackages = "sb") 
public class Application { 

    public static void main(String[] args) throws Throwable { 
     SpringApplication app = new SpringApplication(Application.class); 
     app.run(); 
    } 
}

kaynak

2015-05-23 01:40:10 jimagic

@Qualifier notu yerine kongre ile konfigürasyonu kullanmak mümkün mü? Yani, isim yapılandırma yöntemleri ve aynı ada sahip enjekte edilen özellikler? Denedim ama işe yaramadı. –

Bu veri kaynaklarını jmx ile izlemek de mümkün mü? – sme

UserRepository içindeki niteleyiciyi getUser parametresinin değerine göre değiştirmek mümkün mü? – lorenag83

bu bahar xml dosya üzerinde birden fazla veri kaynağını nasıl oluşturduğuna burada ise örneğin mayın, o İşte

<bean id="dataSource" 
     class="org.springframework.jdbc.datasource.DriverManagerDataSource"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver" /> 
    <property name="url" 
       value="jdbc:mysql://localhost:3306/gl?characterEncoding=UTF-8" /> 
    <property name="username" value="root" /> 
    <property name="password" value="2238295" /> 
</bean> 



<bean id="mainDataSource" 
     class="org.springframework.jdbc.datasource.DriverManagerDataSource"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver" /> 
    <property name="url" 
       value="jdbc:mysql://localhost:3306/gl_main?characterEncoding=UTF-8" /> 
    <property name="username" value="root" /> 
    <property name="password" value="2238295" /> 
</bean> 

<!-- Hibernate 4 SessionFactory Bean definition --> 
<bean id="sfAccounting" 
     class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> 
    <property name="dataSource" ref="dataSource" /> 
    <property name="packagesToScan" value="com.gl.domain.accounting" /> 
    <property name="hibernateProperties"> 
     <props> 
      <prop key="hibernate.connection.useUnicode">true</prop> 
      <prop key="hibernate.connection.characterEncoding">UTF-8</prop> 
      <prop key="hibernate.connection.charSet">UTF-8</prop> 
      <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect 
      </prop> 
      <prop key="hibernate.hbm2ddl.auto">update</prop> 
      <prop key="hibernate.show_sql">false</prop> 
     </props> 
    </property> 
</bean> 



<!-- Hibernate 4 SessionFactory Bean definition --> 
<bean id="sfCommon" 
     class="org.springframework.orm.hibernate4.LocalSessionFactoryBean"> 
    <property name="dataSource" ref="mainDataSource" /> 
    <property name="packagesToScan" value="com.gl.domain.common" /> 
    <property name="hibernateProperties"> 
     <props> 
      <prop key="hibernate.connection.useUnicode">true</prop> 
      <prop key="hibernate.connection.characterEncoding">UTF-8</prop> 
      <prop key="hibernate.connection.charSet">UTF-8</prop> 
      <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect 
      </prop> 
      <prop key="hibernate.hbm2ddl.auto">update</prop> 
      <prop key="hibernate.show_sql">false</prop> 
     </props> 
    </property> 
</bean> 



<tx:annotation-driven transaction-manager="txnManagerAccounting"/> 
<tx:annotation-driven transaction-manager="txnManagerCommon"/> 

<bean id="txnManagerAccounting" 
     class="org.springframework.orm.hibernate4.HibernateTransactionManager"> 
    <property name="sessionFactory" ref="sfAccounting" /> 

</bean> 


<bean id="txnManagerCommon" 
     class="org.springframework.orm.hibernate4.HibernateTransactionManager"> 
    <property name="sessionFactory" ref="sfCommon" /> 

</bean> 

<bean id="persistenceExceptionTranslationPostProcessor" 
     class="org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor" />

kaynak

2015-05-21 01:33:50 jimagic

Jiten, bana yardım etmek için zaman ayırdığınız için teşekkür ederim. Ben XML dosyalarını kullanmam. Application.properties dosyasındaki sadece ek açıklamalar veya özellikler. Saygılarımızla. –

Cevabınızı kullandım ama javax.persistence.TransactionRequiredException alıyorum: İşlem devam ediyor, lütfen https://stackoverflow.com/questions/47430321/inject-2-data-sources-into- Daha fazla bilgi için springhibernate-application-always-throw-no-transact –

Ayrıca, birden çok veri kaynağını tanımlamayı da deneyebilirsiniz: bunlardan birini birincil olarak atamak için &.

İşte demo kodu.

İlköğretim Datasource:

@MapperScan(basePackages = "com.demo.mysqldao", 
sqlSessionFactoryRef = "mysqlSqlSessionFactory") 
@Configuration 
public class MysqlDatabaseConfig { 

    @Value("${mysql.datasource.url}") 
    String jdbcUrl; 

    @Value("${mysql.datasource.username}") 
    String jdbcUser; 

    @Value("${mysql.datasource.password}") 
    String jdbcPass; 

    @Value("${mysql.datasource.driverClassName}") 
    String jdbcProvider; 

    BasicDataSource src = null; 

    Logger log = LoggerFactory.getLogger(MysqlDatabaseConfig.class); 

    @Bean(name = "mysqlDataSource") 
    @Primary 
    @PostConstruct 
    public DataSource mysqlDataSource() { 
    if (jdbcUrl == null) { 
     throw new RuntimeException("initialization datasource error with null jdbcUrl"); 
    } 
    log.info("Using JDBC ------------> " + jdbcUrl); 
    if (src == null) { 
     BasicDataSource dataSource = new BasicDataSource(); 
     dataSource.setDriverClassName(jdbcProvider); 
     dataSource.setUrl(jdbcUrl); 
     dataSource.setUsername(jdbcUser); 
     dataSource.setPassword(jdbcPass); 
     dataSource.setMaxActive(100); 
     dataSource.setMinIdle(3); 
     dataSource.setMaxIdle(10); 
     dataSource.setMinEvictableIdleTimeMillis(60 * 1000); 
     dataSource.setNumTestsPerEvictionRun(100); 
     dataSource.setRemoveAbandoned(true); 
     dataSource.setRemoveAbandonedTimeout(60 * 1000); 
     dataSource.setTestOnBorrow(true); 
     dataSource.setTestOnReturn(true); 
     dataSource.setTestWhileIdle(true); 
     dataSource.setTimeBetweenEvictionRunsMillis(30 * 60 * 1000); 
     src = dataSource; 
    } 
    return src; 
    } 

    @Autowired 
    @Qualifier(value = "mysqlDataSource") 
    DataSource mysqlDataSource; 

    @Bean("mysqlTransactionManager") 
    @Primary 
    public DataSourceTransactionManager mysqlTransactionManager() { 
    return new DataSourceTransactionManager(mysqlDataSource); 
    } 

    @Bean("mysqlSqlSessionFactory") 
    @Primary 
    public SqlSessionFactory mysqlSqlSessionFactory() throws Exception { 
    SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean(); 
    sessionFactory.setDataSource(mysqlDataSource); 
    return sessionFactory.getObject(); 
    }

Başka Veri kaynağı (benim tanıtımda, bu kadar Sqlserver)

@MapperScan(basePackages = "com.demo.sqlserverdao", 
sqlSessionFactoryRef = "sqlserverSqlSessionFactory") 
@Configuration 
public class SQLServerDatabaseConfig { 

    @Value("${sqlserver.datasource.url}") 
    String jdbcUrl; 

    @Value("${sqlserver.datasource.username}") 
    String jdbcUser; 

    @Value("${sqlserver.datasource.password}") 
    String jdbcPass; 

    @Value("${sqlserver.datasource.driverClassName}") 
    String jdbcProvider; 


    BasicDataSource src = null; 

    @Bean(name = "sqlServerDataSource") 
    @PostConstruct 
    public DataSource sqlServerDataSource() { 

    if (jdbcUrl == null) { 
     throw new RuntimeException("initialization sqlserver datasource error with null jdbcUrl"); 
    } 
    if (src == null) { 
     BasicDataSource dataSource = new BasicDataSource(); 
     dataSource.setDriverClassName(jdbcProvider); 
     dataSource.setUrl(jdbcUrl); 
     dataSource.setUsername(jdbcUser); 
     dataSource.setPassword(jdbcPass); 
     dataSource.setMaxActive(100); 
     dataSource.setMinIdle(3); 
     dataSource.setMaxIdle(10); 
     dataSource.setMinEvictableIdleTimeMillis(60 * 1000); 
     dataSource.setNumTestsPerEvictionRun(100); 
     dataSource.setRemoveAbandoned(true); 
     dataSource.setRemoveAbandonedTimeout(60 * 1000); 
     dataSource.setTestOnBorrow(true); 
     dataSource.setTestOnReturn(true); 
     dataSource.setTestWhileIdle(true); 
     dataSource.setTimeBetweenEvictionRunsMillis(30 * 60 * 1000); 
     src = dataSource; 
    } 
    return src; 
    } 

    @Autowired 
    @Qualifier(value = "sqlServerDataSource") 
    DataSource sqlServerDataSource; 

    @Bean("sqlserverTransactionManager") 
    public DataSourceTransactionManager sqlserverTransactionManager() { 
    return new DataSourceTransactionManager(sqlServerDataSource); 
    } 

    @Bean("sqlserverSqlSessionFactory") 
    public SqlSessionFactory sqlserverSqlSessionFactory() throws Exception { 
    SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean(); 
    sessionFactory.setDataSource(sqlServerDataSource); 
    return sessionFactory.getObject(); 
    }

Ref: https://stackoverflow.com/a/27679997/6037575

kaynak

2016-12-16 03:50:52

Yay ile 2 veya daha fazla veritabanı nasıl kullanılır?

cevap

İlgili konular