spring JDBC

       *spring框架对JDBC的简单封装

       *步骤：

       （1）导入jar包

       （2）创建jdbcTemplate对象。依赖于数据源DataSource

              *JdbcTemplate template = new JdbcTemplate(ds)

       （3）调用JdbcTemplate的方法来完成CRUD（对应mysql各个操作如上）操作

              *update():执行DML语句。增删改

              *queryForMap():查询结果将结果集封装为map集合。

                     *注意：这个方法查询的结果集长度只能为1

              *queryForList():查询结果将结果封装为list集合。

                     *注意：将每一条记录封装为一个Map集合，再讲Map集合装载到List集合中

              *query（）：查询结果，将结果封装为JavaBean对象。

                     *query的参数:RowMapper

                            *一般使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自从封装。

                            new BeanPropertyRowMapper<类型>(类型.class)

              *queryForObject：查询结果，将结果封装为对象。

                     一般用于聚合函数的查询

 

示例：

       需求

              1、修改boys表的id为1的userCP为10

              2、添加一条数据

              3、删除刚才添加的记录

              4、查询为1的记录，将其封装为Map集合

              5、查询所有记录，将其封装为List集合

              6、查询所有记录，将其封装为EMP对象的List集合

              7、查询所有记录

对象的实例如下

（1）在一个girls库中，创建一个boys表，如下图所示

（2）首先导入相应的包，（这些包在网上均可以搜到）如下图所示：

（3）配置所有使用库的配置文件druid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/girls
username=mysql的用户名
password=密码
#初始化连接数量
initialSize=5
#最大连接数
maxActive=10
#最大等待时间
maxWait=3000

（4）设置一个加载、连接和释放资源的工具类JDBCUtils.java

package cn.dy.datasource.utls;import com.alibaba.druid.pool.DruidDataSourceFactory;import javax.sql.DataSource;
import java.io.IOException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;/*** Druid连接池的工具类*/
public class JDBCUtils {//1、定义成员变量DataSourceprivate static DataSource ds;static{try {//1、加载配置文件Properties pro = new Properties();pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));//2、获取DataSourceds = DruidDataSourceFactory.createDataSource(pro);} catch (IOException e) {e.printStackTrace();} catch (Exception e) {e.printStackTrace();}}/*** 获取连接方法*/public static Connection getConnection() throws SQLException {return ds.getConnection();}/*** 释放资源*/public static void close(Statement stmt,Connection conn) {if(stmt != null){try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if(conn!=null){try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}public static void close(ResultSet rs,Statement stmt, Connection conn) {if(rs != null){try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if(stmt != null){try {stmt.close();} catch (SQLException e) {e.printStackTrace();}}if(conn!=null){try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}/*** 获取连接池方法*/public static DataSource getDataSource(){return ds;}
}

（5）然后封装列表字段为一个类函数，我命名为Coolboys.java，具体代码如下：

package cn.dy.datasource.domain;public class CoopBoy {private Integer id;private String boyName;private Integer userCP;public int getId() {return id;}public void setId(int id) {this.id = id;}public String getBoyName() {return boyName;}public void setBoyName(String boyName) {this.boyName = boyName;}public int getUserCP() {return userCP;}public void setUserCP(int userCP) {this.userCP = userCP;}@Overridepublic String toString() {return "CoopBoy{" +"id=" + id +", boyName='" + boyName + '\'' +", userCP=" + userCP +'}';}
}

（6）定义个Junit测试类，针对要求设置相应的测试方法JdbcTemplateDemo2.java

package jdbctemplate;import cn.dy.datasource.domain.CoopBoy;
import cn.dy.datasource.utls.JDBCUtils;
import org.junit.Test;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;public class JdbcTemplateDemo2 {//1、获取JDBCTemplate对象JdbcTemplate jdbcTemplate = new JdbcTemplate(JDBCUtils.getDataSource());//Junit单元测试，可以让方法独立执行/*** 1、修改1号数据的salary为10*/@Testpublic void test1(){//2、定义sqlString sql = "update boys set userCP = 10 where id = 1";//3、执行sqlint count = jdbcTemplate.update(sql);System.out.println(count);}/***2、添加一条记录*/@Testpublic void test2(){String sql = "insert into boys(id,boyName,userCP) values(?,?,?)";int count = jdbcTemplate.update(sql, 4, "张三丰", 100);System.out.println(count);}/*** 3、删除刚才添加的记录*/@Testpublic void test3(){String sql = "delete from boys where id = ?";int count = jdbcTemplate.update(sql, 4);System.out.println(count);}/*** 4、查询id为1的记录，将其封装为Map集合* 注意：这个方法查询的结果集长度只能为1*/@Testpublic void test4(){String sql = "select * from boys where id = ?";Map<String, Object> map = jdbcTemplate.queryForMap(sql, 1);System.out.println(map);}/*** 5、查询所有记录，将其封装为List*/@Testpublic void test5(){String sql = "select * from boys";List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);for(Map<String,Object> stringObjectMap:list){System.out.println(stringObjectMap);}}/*** 6、查询所有记录，并封装为list*/@Testpublic void test6_1(){String sql = "select * from boys";List<CoopBoy> list = jdbcTemplate.query(sql, new RowMapper<CoopBoy>() {@Overridepublic CoopBoy mapRow(ResultSet rs, int i) throws SQLException {CoopBoy boy = new CoopBoy();int id = rs.getInt("id");String boyName = rs.getString("boyName");int userCP = rs.getInt("userCP");boy.setId(id);boy.setBoyName(boyName);boy.setUserCP(userCP);return boy;}});for (CoopBoy boy:list) {System.out.println(boy);}}/*** 7、查询所有类，并封装为list*/@Testpublic void test6_2(){String sql = "select * from boys";List<CoopBoy> list = jdbcTemplate.query(sql, new BeanPropertyRowMapper<CoopBoy>(CoopBoy.class));for(CoopBoy boy:list){System.out.println(boy);}}/*** 7、查询所有记录*/@Testpublic void test7(){String sql = "select count(id) from boys";Long total = jdbcTemplate.queryForObject(sql, Long.class);System.out.println(total);}}

测试：当执行test6_2()测试方法时，结果如下

9月 30, 2020 9:47:44 上午 com.alibaba.druid.pool.DruidDataSource info
信息: {dataSource-1} inited
CoopBoy{id=1, boyName='张无忌', userCP=10}
CoopBoy{id=2, boyName='猪八戒', userCP=888}
CoopBoy{id=3, boyName='迪迦', userCP=1000}