source

Spring Boot connect Mysql과 MongoDb

nicesource 2023. 8. 22. 22:13
반응형

Spring Boot connect Mysql과 MongoDb

Spring Boot 어플리케이션에 문제가 있습니다.Spring boot 어플리케이션에서 MongoDB 데이터베이스와 MySql 데이터베이스를 연결하고 싶습니다.만약 가능하다면 긍정적인 경우 어떻게 하면 이 다중 연결을 만들 수 있는지 알고 싶습니다.저는 Mysql과 Post의 예시를 바탕으로 시도했지만 성공하지 못했습니다.그래서 저는 누군가가 그 방법을 알기 쉬운 예를 가지고 있는지 궁금합니다.감사해요.

이것을 하는 것은 가능합니다.다른 데이터 소스에 대해 다른 구성을 생성해야 합니다.이 링크는 http://www.baeldung.com/spring-data-jpa-multiple-databases 에 좋은 예가 있습니다.

또 다른 유용한 스택 오버플로 질문: Spring Boot 두 개의 데이터 소스 구성 및 사용

mongo와 mysql로 시작하려면 spring.io 가이드의 예를 따를 수 있습니다.

https://spring.io/guides/gs/accessing-data-mongodb/

https://spring.io/guides/gs/accessing-data-mysql/

편집:

위의 두 샘플을 병합하여 하나의 예제를 만들었습니다.

package hello;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;

import hello.model.Customer;
import hello.model.User;
import hello.mongodao.CustomerRepository;
import hello.mysqldao.UserRepository;

@EnableMongoRepositories(basePackageClasses = CustomerRepository.class)
@EnableJpaRepositories (basePackageClasses = UserRepository.class)
@SpringBootApplication
public class Application implements CommandLineRunner {

    @Autowired
    private CustomerRepository repository;

    @Autowired
    private UserRepository userRepository;

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
    @Override
    public void run(String... args) throws Exception {

        System.out.println("getting data from Mongo");
        repository.deleteAll();

        // save a couple of customers
        repository.save(new Customer("Alice", "Smith"));
        repository.save(new Customer("Bob", "Smith"));

        // fetch all customers
        System.out.println("Customers found with findAll():");
        System.out.println("-------------------------------");
        for (Customer customer : repository.findAll()) {
            System.out.println(customer);
        }
        System.out.println();

        // fetch an individual customer
        System.out.println("Customer found with findByFirstName('Alice'):");
        System.out.println("--------------------------------");
        System.out.println(repository.findByFirstName("Alice"));

        System.out.println("Customers found with findByLastName('Smith'):");
        System.out.println("--------------------------------");
        for (Customer customer : repository.findByLastName("Smith")) {
            System.out.println(customer);
        }

        System.out.println("gettting data from mysql");
        userRepository.deleteAll();

        // save a couple of customers
        userRepository.save(new User("Alice", "Alice@Smith.com"));
        userRepository.save(new User("Bob", "Bob@Smith.com"));

        // fetch all customers
        System.out.println("Users found with findAll():");
        System.out.println("-------------------------------");

        for (User user : userRepository.findAll()) {
            System.out.println(user);
        }

    }
}

CustomerRepository.java

package hello.mongodao;

import java.util.List;

import org.springframework.data.mongodb.repository.MongoRepository;

import hello.model.Customer;

public interface CustomerRepository extends MongoRepository<Customer, String> {

    public Customer findByFirstName(String firstName);
    public List<Customer> findByLastName(String lastName);

}

UserRepository.java

package hello.mysqldao;

import org.springframework.data.repository.CrudRepository;

import hello.model.User;

// This will be AUTO IMPLEMENTED by Spring into a Bean called userRepository
// CRUD refers Create, Read, Update, Delete

public interface UserRepository extends CrudRepository<User, Long> {

}

Customer.java

package hello.model;

import org.springframework.data.annotation.Id;


public class Customer {

    @Id
    public String id;

    public String firstName;
    public String lastName;

    public Customer() {}

    public Customer(String firstName, String lastName) {
        this.firstName = firstName;
        this.lastName = lastName;
    }

    @Override
    public String toString() {
        return String.format(
                "Customer[id=%s, firstName='%s', lastName='%s']",
                id, firstName, lastName);
    }

}

User.java

package hello.model;

import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;

@Entity // This tells Hibernate to make a table out of this class
public class User {
    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    private Integer id;

    private String name;

    private String email;
public User() {
    // TODO Auto-generated constructor stub
}
    public User(String string, String string2) {
        // TODO Auto-generated constructor stub
        name = string;
        email = string2;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    @Override
    public String toString() {
        return String.format(
                "User[id=%s, name='%s', email='%s']",
                id, name, email);
    }


}

application.properties

spring.jpa.hibernate.ddl-auto=create
spring.datasource.url=jdbc:mysql://localhost:3306/db_example
spring.datasource.username=springuser
spring.datasource.password=ThePassword
spring.data.mongodb.uri=mongodb://localhost:27017/local

MongoDB는 sql과 속성 이름이 다르므로 추가 구성 및 속성 파일을 만들 필요가 없습니다. 따라서 application.properties 파일만 있으면 됩니다.

application.properties

spring.datasource.url=jdbc:mysql://${MYSQL_HOST:localhost}:3306/dbName?useUnicode=yes&characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=

spring.data.mongodb.uri=mongodb://localhost:27017
spring.data.mongodb.database=dbName

예제 모형

MongoDB 문서

import org.springframework.data.mongodb.core.mapping.Document;
import javax.persistence.Id;

    @Document("Gyros")
    public class Gyros {
    
        public Gyros(String description) {
            this.description = description;
        }
    
        @Id
        public String id;
    
        public String description;
    }

Mysql JPA 엔티티

import javax.persistence.*;

@Entity
@Table(name = "Kebab")
public class Kebab {

    public Kebab(String description) {
        this.description = description;
    }

    public Kebab() {
    }

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    public int id;

    public String description;
}

MongoDB 저장소

@Repository
public interface GyrosRepository extends MongoRepository<Gyros, String> {
}

Mysql Jpa 저장소

    @Repository
    public interface KebabRepository extends JpaRepository<Kebab, Integer> {
    }

테스트 서비스

@org.springframework.stereotype.Service
public class Service {

    private final GyrosRepository gyrosRepository;
    private final KebabRepository kebabRepository;

    @Autowired
    public Service(GyrosRepository gyrosRepository, KebabRepository kebabRepository) {
        this.gyrosRepository = gyrosRepository;
        this.kebabRepository = kebabRepository;
    }

    @PostConstruct
    void test() {
        this.gyrosRepository.insert(new Gyros("ham ham"));
        this.kebabRepository.saveAndFlush(new Kebab("yum yum"));
    }
}

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.2.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>org.example</groupId>
    <artifactId>stack</artifactId>
    <version>1.0-SNAPSHOT</version>
    <name>stackoverflow</name>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-mongodb</artifactId>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
    </dependencies>

</project>

저도 같은 종류의 문제에 직면한 적이 있습니다.스프링 부팅 애플리케이션을 두 개의 다른 데이터베이스에 연결해야 했습니다.하나는 Mongodb이고 다른 하나는 Postgres db입니다.

JPA와 spring-boot-starter-data-mongodb를 모두 사용한 것을 알 수 있습니다.그래도 제 프로젝트는 아주 잘 진행되고 있습니다.당신에게도 그것이 성공적으로 작동하기를 바랍니다.인터넷을 통해 JPA를 사용하지 말라는 제안이 있지만 JPA를 포함하지 않으면 JPA 저장소를 사용할 수 없습니다.

저에게 효과가 있었던 솔루션을 게시합니다.

누군가에게 도움이 되길 바랍니다.

  1. application.properties 파일:

    MONGODB(Mongo 속성)

    spring.data.mongodb.uri=mongodb://XX.XX.XX:27017/testdb

    #POSTGRES properties
    spring.datasource.platform=postgres
    spring.datasource.url= jdbc:postgresql://localhost:5432/database_name    
    spring.datasource.username=postgres_usr_name
    spring.datasource.password=postgres_pwd
    spring.jpa.properties.hibernate.jdbc.lob.non_contextual_creation=true

  2. 내 폼 종속성:

    <dependencies>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>   
<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
</dependency> 
<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
</dependency> 
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>

  3. 리포지토리를 사용하여 데이터에 액세스하는 방법:

    : MONGO 저장소

      import org.springframework.data.mongodb.repository.MongoRepository;
    public interface MRepositories extends MongoRepository<YourEntityClass, String>{
        }

    (ii): JPA 저장소

    @Repository public interface PostGresRepo extends JpaRepository<TestEntity,Long> {}

언급URL : https://stackoverflow.com/questions/44507705/spring-boot-connect-mysql-and-mongodb

반응형

'source' 카테고리의 다른 글

CSS에서 !important는 무엇을 의미합니까?  (0) 2023.08.22
이 CSS는 어떻게 원을 생성합니까?  (0) 2023.08.22
PowerShell을 사용한 종속성 주입  (0) 2023.08.22
파워셸 스크립트를 사용하여 두 폴더를 동기화하는 방법  (0) 2023.08.22
MariaDB: 대량 삽입 작업을 활성화하는 방법  (0) 2023.08.22

'source'의 다른글

  • 현재글Spring Boot connect Mysql과 MongoDb

관련글

댓글

티스토리툴바