springBoot使用JdbcTemplate代码实例

springBoot使用JdbcTemplate代码实例

springBoot使用JdbcTemplate

如果是通过spring自动注入的jdbcTemplate，配好application.properties在其他类中就能在其他类中直接使用。

如果通过new JdbcTemplate()出来的就需要自己配置DataSource。

自动注入如下

application.properties文件

spring.datasource.url=jdbc:mysql://localhost:3306/test?serverTimezone=UTC

spring.datasource.username=root

spring.datasource.password=root

spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.type=com.alibaba.druid.pool.DruidDataSourceC3P0Adapter

UserDao

package com.example.demo.dao;

import com.example.demo.pojo.UserInfo;

import org.springframework.jdbc.core.JdbcTemplate;

import org.springframework.jdbc.core.PreparedStatementCreator;

import org.springframework.jdbc.core.RowMapper;

import org.springframework.jdbc.support.GeneratedKeyHolder;

import org.springframework.jdbc.support.KeyHolder;

import org.springframework.stereotype.Repository;

import javax.annotation.Resource;

import java.sql.*;

import java.util.ArrayList;

import java.util.List;

@Repository

public class UserDao {

@Resource

private JdbcTemplate jdbcTemplate;

public UserInfo createUser(UserInfo u) {

String sql = "insert into user(name,address) values(?,?)";

KeyHolder holder=new GeneratedKeyHolder();

jdbcTemplate.update(new PreparedStatementCreator() {

public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {

PreparedStatement ps=conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);

ps.setString(1, u.getName());

ps.setString(2, u.getAddress());

return ps;

}

}, holder);

int insertId=holder.getKey().intValue();

u.setId(insertId);

return u;

}

public void createUserList() {

String sql="insert into user (name,address) values (?,?)";

List

batchArgs.add(new Object[]{"caoyc","北京"});

batchArgs.add(new Object[]{"zhh","重庆"});

batchArgs.add(new Object[]{"cjx","天津"});

jdbcTemplate.batchUpdate(sql, batchArgs);

}

public void deleteUser(int id) {

String sql="delete from user where id=?";

jdbcTemplate.update(sql, new Object[] {id},new int[] {java.sql.Types.INTEGER});

}

public void updateUser(UserInfo u) {

String sql="update user set name=? where id=?";

jdbcTemplate.update(sql, new Object[] {u.getName(),u.getId()});

}

public List queryUser(int id) {

String sql="select * from user where id=?";

// RowMapper rowMapper = new BeanPropertyRowMapper<>(UserInfo.class);

return jdbcTemplate.query(sql,new Object[] {id},new UserRowMapper());

}

class UserRowMapper implements RowMapper {

public UserInfo mapRow(ResultSet res, int arg1) throws SQLException {

UserInfo u=new UserInfo();

u.setId(res.getInt("id"));

u.setName(res.getString("name"));

u.setAddress(res.getString("address"));

return u;

}

}

}

手动配置如下

DriverManagerDataSource dataSource=new DriverManagerDataSource();

dataSource.setDriverClassName("org.postgresql.Driver");

dataSource.setUrl("jdbc:postgresql://127.0.0.1:5432/postgres");

dataSource.setUsername("postgres");

dataSource.setPassword("332578");

JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。