千家信息网

请输入关键字词

热门搜索排行

最新搜索排行

导航： 首页 > 互联网科技 >

SpringBoot中怎么配置Jpa多数据源

发表于：2025-01-27 作者：千家信息网编辑
千家信息网最后更新 2025年01月27日，SpringBoot中怎么配置Jpa多数据源，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。1.application.yml文件中，
千家信息网最后更新 2025年01月27日SpringBoot中怎么配置Jpa多数据源

SpringBoot中怎么配置Jpa多数据源，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

1.application.yml文件中，配置数据库源。这里primary是主库，secondary是从库。

server:  port: 8089# 多数据源配置#primaryspring:  primary:    datasource:      url: jdbc:mysql://127.0.0.1:3306/database1?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai      username: root      password: ******      driver-class-name: com.mysql.jdbc.Driver  #secondary  secondary:    datasource:      url: jdbc:mysql://127.0.0.1:3306/database1?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghai      username: root      password: ******      driver-class-name: com.mysql.jdbc.Driver  jpa:    hibernate:      primary-dialect: org.hibernate.dialect.MySQL5Dialect      secondary-dialect: org.hibernate.dialect.MySQL5Dialect    open-in-view: true    show-sql: true

2.创建一个Spring配置类，其中spring.primary.datasource的路径参考yml文件的配置。

@Configurationpublic class DataSourceConfig {    @Bean(name = "primaryDataSource")    @Qualifier("primaryDataSource")    @ConfigurationProperties(prefix="spring.primary.datasource")    public DataSource primaryDataSource() {        return DataSourceBuilder.create().build();    }    @Bean(name = "secondaryDataSource")    @Qualifier("secondaryDataSource")    @Primary    @ConfigurationProperties(prefix="spring.secondary.datasource")    public DataSource secondaryDataSource() {        return DataSourceBuilder.create().build();    }}

3.分别创建主库、从库的配置类。
注意：entity包和dao包的配置，以及@Primary注解指定主库。

主库配置类：

@Configuration@EnableTransactionManagement@EnableJpaRepositories(        entityManagerFactoryRef = "entityManagerFactoryPrimary",        transactionManagerRef = "transactionManagerPrimary",        basePackages = {"com.xxx.xxx.dao.primary"}) //设置Repository所在位置public class PrimaryConfig {    @Autowired    private JpaProperties jpaProperties;    @Autowired    @Qualifier("primaryDataSource")    private DataSource primaryDataSource;    @Primary    @Bean(name = "entityManagerPrimary")    public EntityManager entityManager(EntityManagerFactoryBuilder builder) {        return entityManagerFactoryPrimary(builder).getObject().createEntityManager();    }    @Primary    @Bean(name = "entityManagerFactoryPrimary")    public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary(EntityManagerFactoryBuilder builder) {        return builder                .dataSource(primaryDataSource)                .properties(getVendorProperties(primaryDataSource))                .packages("com.infinitus.yunxiao_data.entity.primary") //设置实体类所在位置                .persistenceUnit("primaryPersistenceUnit")                .build();    }    private Map getVendorProperties(DataSource dataSource) {        return jpaProperties.getHibernateProperties(dataSource);    }    @Primary    @Bean(name = "transactionManagerPrimary")    public PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) {        return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject());    }}

从库的配置类：

@Configuration@EnableTransactionManagement@EnableJpaRepositories(        entityManagerFactoryRef = "entityManagerFactorySecondary",        transactionManagerRef = "transactionManagerSecondary",        basePackages = {"com.infinitus.yunxiao_data.dao.secondary"}) //设置Repository所在位置public class SecondaryConfig {    @Autowired    private JpaProperties jpaProperties;    @Autowired    @Qualifier("secondaryDataSource")    private DataSource secondaryDataSource;    @Bean(name = "entityManagerSecondary")    public EntityManager entityManager(EntityManagerFactoryBuilder builder) {        return entityManagerFactorySecondary(builder).getObject().createEntityManager();    }    @Bean(name = "entityManagerFactorySecondary")    public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary(EntityManagerFactoryBuilder builder) {        return builder                .dataSource(secondaryDataSource)                .properties(getVendorProperties(secondaryDataSource))                .packages("com.xxx.xxx.entity.secondary") //设置实体类所在位置                .persistenceUnit("primaryPersistenceUnit")                .build();    }    private Map getVendorProperties(DataSource dataSource) {        return jpaProperties.getHibernateProperties(dataSource);    }    @Bean(name = "transactionManagerSecondary")    PlatformTransactionManager transactionManagerSecondary(EntityManagerFactoryBuilder builder) {        return new JpaTransactionManager(entityManagerFactorySecondary(builder).getObject());    }}

4.分别创建主、从库dao类。
主dao：

@Repositorypublic interface PrimaryRepository extends JpaRepository {    @Query(value = "SELECT p FROM PrimaryEntity p")    List queryList();}

从dao：

@Repositorypublic interface SecondaryRepository extends JpaRepository {    @Query(value = "SELECT p FROM SecondaryEntity p")    List queryList();}

5.分别创建主、从库entity类。
主entity：

@Entity@Table(name = "holiday_scheme")@EntityListeners(AuditingEntityListener.class)public class PrimaryEntity extends AbstractPersistable {    @Column(name = "date")    public String date;    @Column(name = "hour")    public String hour;    @Column(name = "holiday")    public String holiday;    @Column(name = "holiday_explain")    public String holiday_explain;    public String getDate() {        return date;    }    public void setDate(String date) {        this.date = date;    }    public String getHour() {        return hour;    }    public void setHour(String hour) {        this.hour = hour;    }    public String getHoliday() {        return holiday;    }    public void setHoliday(String holiday) {        this.holiday = holiday;    }    public String getHoliday_explain() {        return holiday_explain;    }    public void setHoliday_explain(String holiday_explain) {        this.holiday_explain = holiday_explain;    }    @Override    public String toString() {        return "PrimaryEntity{" +                "date='" + date + '\'' +                ", hour='" + hour + '\'' +                ", holiday='" + holiday + '\'' +                ", holiday_explain='" + holiday_explain + '\'' +                '}';    }}

从entity：

@Entity@Table(name = "active_dashboards")@EntityListeners(AuditingEntityListener.class)public class SecondaryEntity extends AbstractPersistable {    @Column(name = "dashboard_id")    public String dashboard_id;    @Column(name = "user_id")    public String user_id;    @Column(name = "order_index")    public String order_index;    public String getDashboard_id() {        return dashboard_id;    }    public void setDashboard_id(String dashboard_id) {        this.dashboard_id = dashboard_id;    }    public String getUser_id() {        return user_id;    }    public void setUser_id(String user_id) {        this.user_id = user_id;    }    public String getOrder_index() {        return order_index;    }    public void setOrder_index(String order_index) {        this.order_index = order_index;    }    @Override    public String toString() {        return "SecondaryEntity{" +                "dashboard_id='" + dashboard_id + '\'' +                ", user_id='" + user_id + '\'' +                ", order_index='" + order_index + '\'' +                '}';    }}

6.controller请求获取不同数据库的数据。

@RestController@RequestMapping("/database")public class MailController {    private final Logger logger = LoggerFactory.getLogger(this.getClass());    @Autowired    PrimaryRepository primaryRepository;    @Autowired    SecondaryRepository secondaryRepository;    @RequestMapping("/primary")    @ResponseBody    public String primary() {        return primaryRepository.queryList().toString();    }    @RequestMapping("/secondary")    @ResponseBody    public String secondary() {        return secondaryRepository.queryList().toString();    }}
注意

下面提两个在配置多数据源时遇到的坑点，一不注意就掉坑了。
1.Application类不需要配置@EnableJpaRepositories注解，会报如下错误。

A component required a bean named 'entityManagerFactory' that could not be f

2.注意检查dao类，获取数据的方法上格式是否正确，有没有某个字段是表中不存在的，避免启动异常。如下，SecondaryEntity表中是不存在job_name字段的，所以注释掉才能启动成功等。

//@Query(value = "SELECT p FROM SecondaryEntity p where p.job_name = ?1")//List queryOdcRecord(String job_name);

关于SpringBoot中怎么配置Jpa多数据源问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注行业资讯频道了解更多相关知识。

很赞哦！
配置 数据 数据源 位置 所在 问题 字段 实体 数据库 文件 方法 更多 注解 帮助 解答 不同 易行 成功 简单易行 两个 数据库的安全要保护哪些东西 数据库安全各自的含义是什么 生产安全数据库录入 数据库的安全性及管理 数据库安全策略包含哪些 海淀数据库安全审计系统 建立农村房屋安全信息数据库 易用的数据库客户端支持安全管理 连接数据库失败ssl安全错误 数据库的锁怎样保障安全 汕头卫星软件开发价格走势 门禁数据如何转为考勤数据库 佛山安卓软件开发怎么样 服务器 安装iis 某某公司网络安全需求分析 网络安全公安工作 无法打开登录 数据库 成都打车有什么软件开发 服务器调整等保需要重新定级么 杭州财宝网络技术 js中如何查询数据库表 网络安全源头的意识 华为服务器风扇告警怎么关 网络安全工作的机遇与挑战 广州长丰网络技术电话 津门论剑共话网络安全 服务器安装项目管理 目前最新的软件开发技术 网络安全知识动画 网络安全手抄报背景颜色 保亭软件开发 服务器 安装iis 数据库上机实验存储过程 软件开发公司简章 通信信息网络安全许可 云众联互联网科技有限公司 有关网络安全教育的文案 做一个家庭网络安全检测工作 金融网络技术发展 网络安全研判记录

相关文章

0