向sql添加数据

Question

目前，我学习如何使用SpringBoot和访问多个数据库。在学习过程中，我遇到了向mysql表添加数据的问题。在我使用插入。。。。Value（）要添加数据，当我使用get方法（SpringBoot）在网站上查找（显示）数据时，表仍然显示为null（无数据）。你们能就我的错误给我一些建议吗。

• 额外信息：我把mysql表放在SpringBoot的资源文件夹中。当我使用get方法（Springboot的findallValue）时，我希望看到我添加到表中的值存在于网站上

这是我的代码：

MYSQL表

CREATE TABLE  Tax (

 id INT(6),

 taxable_income VARCHAR(50) ,

 addition_charge DECIMAL(10,2) ,

 charge_every_one_dollar DECIMAL(10,2),


 primary key (id)
);

INSERT INTO Tax (id,taxable_income,  addition_charge , charge_every_one_dollar ) 
VALUES  (1,"$0 - $18,200" , 0 , 0);

配置

import org.apache.commons.dbcp.BasicDataSource;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;

import javax.sql.DataSource;

import com.example.demo.Entity.table.Tax;

@Configuration
@EnableJpaRepositories(basePackages = "com.example.demo.Repo.table",
        entityManagerFactoryRef = "TaxEntityManagerFactory",
        transactionManagerRef= "TaxTransactionManager")
public class TaxTableConfiguration {

    @Bean
    @ConfigurationProperties("app.datasource.tax")
    public DataSourceProperties TaxDataSourceProperties() {
        return new DataSourceProperties();
    }

    @Bean
    @ConfigurationProperties("app.datasource.tax.configuration")
    public DataSource TaxDataSource() {
        return TaxDataSourceProperties().initializeDataSourceBuilder()
                .type(BasicDataSource.class).build();
    }

    @Bean(name = "TaxEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean TaxEntityManagerFactory(
            EntityManagerFactoryBuilder builder) {
        return builder
                .dataSource(TaxDataSource())
                .packages(Tax.class)
                .build();
    }

    @Bean
    public PlatformTransactionManager TaxTransactionManager(
            final @Qualifier("TaxEntityManagerFactory") LocalContainerEntityManagerFactoryBean TaxEntityManagerFactory) {
        return new JpaTransactionManager(TaxEntityManagerFactory.getObject());
    }
}

主控制器

package com.example.demo;

import com.example.demo.Entity.table.Tax;
import com.example.demo.Entity.use.User;
import com.example.demo.Repo.table.TaxtableRepository;
import com.example.demo.Repo.use.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

@RestController // This means that this class is a Controller
@RequestMapping(path="/demo") // This means URL's start with /demo (after Application path)
public class MainController {
  @Autowired // This means to get the bean called userRepository
         // Which is auto-generated by Spring, we will use it to handle the data
  private UserRepository userRepository;
  

  @Autowired 
  private TaxtableRepository taxRepository;

  @PostMapping(path="/add") // Map ONLY POST Requests
  public @ResponseBody String addNewUser (@RequestParam String fname,@RequestParam String lname,
  @RequestParam Integer p_a_salary,@RequestParam Float super_rate,@RequestParam String payment_date ) {
    // @ResponseBody means the returned String is the response, not a view name
    // @RequestParam means it is a parameter from the GET or POST request

    User n = new User();
    n.setlName(lname);
    n.setfName(fname);
    n.set_payment_date(payment_date);
    n.set_anual_salary(p_a_salary);
    n.set_super_rate(super_rate);
    userRepository.save(n);
    return "Saved";
  }
  
  @GetMapping(path="/tax")
  public @ResponseBody Iterable<Tax> getAllTaxs() {
    // This returns a JSON or XML with the users
    return taxRepository.findAll();
  }
  
  @GetMapping(path="/all")
  public @ResponseBody Iterable<User> getAllUsers() {
    // This returns a JSON or XML with the users
    return userRepository.findAll();
  }
}

实体

package com.example.demo.Entity.table;

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 Tax {
  @Id
  @GeneratedValue(strategy=GenerationType.AUTO)
  private Long id;

  private String  taxable_income;

  private Double  addition_charge;
  
  private Double  charge_every_one_dollar;

  
  public Long getId() {
    return id;
  }

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

  public String get_TaxableIncome() {
    return taxable_income;
  }

  public void set_TaxableIncome(String taxable_income) {
    this.taxable_income = taxable_income;
  }

  public Double get_addition_charge() {
    return addition_charge;
  }

  public void set_additonal_charge(Double addition_charge) {
    this.addition_charge = addition_charge;
  }

  public Double get_charge_every_one_dollar() {
    return charge_every_one_dollar;
  }

  public void set_charge_every_one_dollar(Double charge_every_one_dollar) {
    this.charge_every_one_dollar = charge_every_one_dollar;
  }


  
}

应用

#first  db : 

app.datasource.user.url=jdbc:mysql://${MYSQL_HOST:localhost}:3306/taxdb
app.datasource.user.username=user
app.datasource.user.password=password
app.datasource.driverClassName=com.mysql.cj.jdbc.Driver

#second db: 
app.datasource.tax.url=jdbc:mysql://${MYSQL_HOST:localhost}:3306/calculatedb
app.datasource.tax.username=user
app.datasource.tax.password=password
app.datasource.tax.driverClassName=com.mysql.cj.jdbc.Driver


spring.jpa.hibernate.ddl-auto=update
spring.jpa.properties.hibernate.dialect=org.hibernate.dialect.MySQL5Dialect
spring.jpa.show-sql=true
spring.jpa.database=mysql
spring.jpa.open-in-view=true
server.port = 8080
# spring.profiles.active=@spring.profil

资料库

package com.example.demo.Repo.table;

 

import com.example.demo.Entity.table.Tax;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;


@Repository
public interface TaxtableRepository extends JpaRepository<Tax ,Integer> {

}

我把我的mysql文件放在Springboot里

Answer 1

查看此链接https://www.baeldung.com/spring-boot-data-sql-and-schema-sql

您可以将文件添加到类路径中，即src/main/resources文件夹中，spring将自动检测并执行您的文件。希望这能帮到你。