java Spring 启动 jdbc 连接

Spring boot jdbc Connection

提问by Raffaele

i'm trying to configure spring boot in order to have tomcat connection pool to my production database. My application is NOT web (i have also some difficult to tell that to spring).

我正在尝试配置 spring boot 以便将 tomcat 连接池连接到我的生产数据库。我的应用程序不是网络（我也很难告诉春天）。

I have a Startup class and 3 more classes

我有一个 Startup 课程和另外 3 个课程

the code

代码

@Configuration

@EnableAutoConfiguration(exclude = DataSourceAutoConfiguration.class)

public class Starter {

private static Logger logger;

@Autowired
private static MyController controller;

public static void main(String[] args) {

//      SpringApplication.setWebEnvironment(false);

    SpringApplication.run(Starter.class, args);

    LogbackConfigLoader lcl = new LogbackConfigLoader();
    if (lcl.init()) {
        logger = LoggerFactory.getLogger(Starter.class);
        logger.debug("Initialized....");
    }
    else{
        logger = LoggerFactory.getLogger(Starter.class);
    }


    logger.info(controller.getProva());

}


}

here is the configuration `

这是配置`

@Configuration

@ConfigurationProperties(prefix="datasource.NIS")

public class NISDBConfiguration {

private String jdbcInterceptors;
private long validationInterval = 30000;

private org.apache.tomcat.jdbc.pool.DataSource pool;

@Value("${driver-class-name}")
private String driverClassName;

@Value("${url}")
private String url;

@Value("${username}")
private String username;

@Value("${password}")
private String password;

@Value("${maxActive}")
private int maxActive = 30;

@Value("${maxIdle}")
private int maxIdle = 8;

@Value("${minIdle}")
private int minIdle = 8;

@Value("${initialSize}")
private int initialSize = 10;

private String validationQuery;

private boolean testOnBorrow;

private boolean testOnReturn;

private boolean testWhileIdle;

private Integer timeBetweenEvictionRunsMillis;

private Integer minEvictableIdleTimeMillis;

private Integer maxWaitMillis;

public String getJdbcInterceptors() {
    return jdbcInterceptors;
}

public void setJdbcInterceptors(String jdbcInterceptors) {
    this.jdbcInterceptors = jdbcInterceptors;
}

public long getValidationInterval() {
    return validationInterval;
}

public void setValidationInterval(long validationInterval) {
    this.validationInterval = validationInterval;
}

public org.apache.tomcat.jdbc.pool.DataSource getPool() {
    return pool;
}

public void setPool(org.apache.tomcat.jdbc.pool.DataSource pool) {
    this.pool = pool;
}

public String getDriverClassName() {
    return driverClassName;
}

public void setDriverClassName(String driverClassName) {
    this.driverClassName = driverClassName;
}

public String getUrl() {
    return url;
}

public void setUrl(String url) {
    this.url = url;
}

public String getUsername() {
    return username;
}

public void setUsername(String username) {
    this.username = username;
}

public String getPassword() {
    return password;
}

public void setPassword(String password) {
    this.password = password;
}

public int getMaxActive() {
    return maxActive;
}

public void setMaxActive(int maxActive) {
    this.maxActive = maxActive;
}

public int getMaxIdle() {
    return maxIdle;
}

public void setMaxIdle(int maxIdle) {
    this.maxIdle = maxIdle;
}

public int getMinIdle() {
    return minIdle;
}

public void setMinIdle(int minIdle) {
    this.minIdle = minIdle;
}

public int getInitialSize() {
    return initialSize;
}

public void setInitialSize(int initialSize) {
    this.initialSize = initialSize;
}

public String getValidationQuery() {
    return validationQuery;
}

public void setValidationQuery(String validationQuery) {
    this.validationQuery = validationQuery;
}

public boolean isTestOnBorrow() {
    return testOnBorrow;
}

public void setTestOnBorrow(boolean testOnBorrow) {
    this.testOnBorrow = testOnBorrow;
}

public boolean isTestOnReturn() {
    return testOnReturn;
}

public void setTestOnReturn(boolean testOnReturn) {
    this.testOnReturn = testOnReturn;
}

public boolean isTestWhileIdle() {
    return testWhileIdle;
}

public void setTestWhileIdle(boolean testWhileIdle) {
    this.testWhileIdle = testWhileIdle;
}

public Integer getTimeBetweenEvictionRunsMillis() {
    return timeBetweenEvictionRunsMillis;
}

public void setTimeBetweenEvictionRunsMillis(
        Integer timeBetweenEvictionRunsMillis) {
    this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
}

public Integer getMinEvictableIdleTimeMillis() {
    return minEvictableIdleTimeMillis;
}

public void setMinEvictableIdleTimeMillis(Integer minEvictableIdleTimeMillis) {
    this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
}

public Integer getMaxWaitMillis() {
    return maxWaitMillis;
}

public void setMaxWaitMillis(Integer maxWaitMillis) {
    this.maxWaitMillis = maxWaitMillis;
} 

@Bean(name = "dsNIS") 
public DataSource dataSource() { 
    this.pool = new org.apache.tomcat.jdbc.pool.DataSource();
    this.pool.setDriverClassName(getDriverClassName());
    this.pool.setUrl(getUrl());
    this.pool.setUsername(getUsername());
    this.pool.setPassword(getPassword());
    this.pool.setInitialSize(getInitialSize());
    this.pool.setMaxActive(getMaxActive());
    this.pool.setMaxIdle(getMaxIdle());
    this.pool.setMinIdle(getMinIdle());
    this.pool.setTestOnBorrow(isTestOnBorrow());
    this.pool.setTestOnReturn(isTestOnReturn());
    this.pool.setTestWhileIdle(isTestWhileIdle());

    if (getTimeBetweenEvictionRunsMillis() != null) {
        this.pool
                .setTimeBetweenEvictionRunsMillis(getTimeBetweenEvictionRunsMillis());
    }
    if (getMinEvictableIdleTimeMillis() != null) {
        this.pool.setMinEvictableIdleTimeMillis(getMinEvictableIdleTimeMillis());
    }
    this.pool.setValidationQuery(getValidationQuery());
    this.pool.setValidationInterval(this.validationInterval);
    if (getMaxWaitMillis() != null) {
        this.pool.setMaxWait(getMaxWaitMillis());
    }
    if (this.jdbcInterceptors != null) {
        this.pool.setJdbcInterceptors(this.jdbcInterceptors);
    }
    return this.pool;

} 

@PreDestroy
public void close() {
    if (this.pool != null) {
        this.pool.close();
    }
}

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

} `

}`

the repository

存储库

package org.hp.data;

@Repository

public class NisRepository {

protected final Logger log = LoggerFactory.getLogger(getClass()); 


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


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

private static final RowMapper<String> itemMapper = new RowMapper<String>() {
    @Override
    public String mapRow(ResultSet rs, int rowNum) throws SQLException { 
        String item = rs.getString("title"); 
        return item; 
    } 
};


public JdbcTemplate getJdbc() {
    return jdbc;
}

public void setJdbc(JdbcTemplate jdbc) {
    this.jdbc = jdbc;
} 

}

}

the controller

控制器

@Controller
public class MyController {


@Autowired 
private NisRepository items; 

public NisRepository getItems() {
    return items;
}

public void setItems(NisRepository items) {
    this.items = items;
}

public String getProva(){
    return items.getItem(10);
}

}

}

But i always get exception when running the application of NullPointerException because MyController is not autowired and is always null.

但是在运行 NullPointerException 应用程序时我总是遇到异常，因为 MyController 不是自动装配的并且始终为空。

I also try to create a new instance with new (but i believe that this is not correct because of the spring mvc pattern).

我也尝试用 new 创建一个新实例（但我认为这是不正确的，因为 spring mvc 模式）。

What is the problem here?

这里有什么问题？

Thanks in advance

提前致谢

回答by M. Deinum

You are using Spring Boot but are trying very hard not to use it. You also state you aren't using a web application but then why do you have a @Controller?

您正在使用 Spring Boot，但正在努力不使用它。您还声明您没有使用 Web 应用程序，但是为什么要使用@Controller?

To fix your problem remove the configuration of the DataSourceand JdbcTemplateSpring Boot will configure those for you. This basically means remove your NISDBConfigurationclass. Just add the correct properties to the application.propertiesfile.

为了解决您的问题删除的配置DataSource和JdbcTemplate春天开机时会配置这些你。这基本上意味着删除您的NISDBConfiguration课程。只需将正确的属性添加到application.properties文件中即可。

spring.datasource.driver-class-name=<your-driver-here>
spring.datasource.url=<your-url>
spring.datasource.username=<your-username>
spring.datasource.password=<your-password>

And of course the other properties you need, check the reference guidefor more properties.

当然还有您需要的其他属性，请查看参考指南以获取更多属性。

Remove the @Qualifierfrom the JdbcTemplateproperty in your repository and you also don't need the getter and setter. I would suggest using constructor based injection.

@Qualifier从JdbcTemplate存储库中的属性中删除，您也不需要 getter 和 setter。我建议使用基于构造函数的注入。

package org.hp.data;

@Repository
public class NisRepository {

    protected final Logger log = LoggerFactory.getLogger(getClass()); 

    protected final JdbcTemplate jdbc; 

    @Autowired
    public NisRepository(JdbcTemplate jbc) {
        this.jdbc=jdbc;
    }

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


    private static final RowMapper<String> itemMapper = new RowMapper<String>() {
        @Override
        public String mapRow(ResultSet rs, int rowNum) throws SQLException { 
            String item = rs.getString("title"); 
            return item; 
        } 
    };

}

If you don't have a web application replace @Controllerwith @Service.

如果您没有 Web 应用程序，请替换@Controller为@Service.

Then rewrite your starter class.

然后重写你的入门课程。

@SpringBootApplication
public class Starter {

    private static Logger logger;

    public static void main(String[] args) {

    //      SpringApplication.setWebEnvironment(false);

        ApplicationContext ctx = SpringApplication.run(Starter.class, args);

        LogbackConfigLoader lcl = new LogbackConfigLoader();
        if (lcl.init()) {
            logger = LoggerFactory.getLogger(Starter.class);
            logger.debug("Initialized....");
        }
        else{
            logger = LoggerFactory.getLogger(Starter.class);
        }

        MyController controller = ctx.getBean(MyController.class);
        logger.info(controller.getProva());

    }


}

Looks like you are also trying to circument spring boots config loading here? Try to work with the framework not against it.

看起来您也在尝试绕过 spring boots 配置加载？尝试使用框架而不是反对它。

If you don't have a web application don't include the spring-boot-starter-webin your dependencies and also make sure you don't have any other web related things in there. Spring Boot auto detects the web environment and tries to bootstrap classes for that, if those aren't there it will just run as a plain java application.

如果您没有 Web 应用程序，请不要将 包含spring-boot-starter-web在您的依赖项中，并确保其中没有任何其他与 Web 相关的内容。Spring Boot 自动检测 Web 环境并尝试为此引导类，如果这些类不存在，它将仅作为普通的 Java 应用程序运行。