SpringJDBC解析1-使用示例

JDBC（Java Data Base Connectivity,Java数据库连接）是一种用于执行SQL语句的JavaAPI，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC为数据库开发人员提供了一个标准的API，据此可以构建更高级的工具和接口，使数据库开发人员能够用纯JavaAPI编写数据库应用程序，并且可跨平台运行，并且不受数据库供应商的限制。
JDBC连接数据库的流程及其原理如下：

1. 在开发环境中加载指定数据库的驱动程序。(Oracle用的包是oracle6-1.0.6.jar，MySQL用的是mysql-connector-java-5.1.18-bin.jar)。
2. 在java程序中加载驱动程序。在java程序中，可以通过“Class.forName("com.mysql.jdbc.Driver")”加载MySQL的数据驱动程序。
3. 创建数据库连接对象。通过DriverManager类创建数据库连接对象Connection.DriverManager类作用于Java程序和JDBC驱动程序之间，用于检查所加载的驱动程序是否可以建立连接，然后通过它的getConnection方法根据数据库的URL，用户名和密码，创建一个JDBC Connnection对象，例如：Connection connection=DriverManager.getConnection("连接数据库的URL","用户名","密码")。其中，URL=协议名+IP地址（域名）+端口+数据库名称；例如：Connection connectMySQL = DriverManager.getConnection("jdbc:mysql://localhost:3306/myuser","root","root");
4. 创建Statement对象。Statement类的主要作用是用于执行静态SQL语句并返回它所生成结果的对象。通过Connection对象的createStatement()方法可以创建一个Statement对象。例如：Statement statement = connectMySQL.createStatement();
5. 调用Statement对象的相关方法执行相应的SQL语句。通过excuteUpdate（）方法来对数据更新，包括插入和删除操作，例如向staff表中插入一条数据的代码。statement.excuteUpdate("INSERT INTO staff(name,age,sex,address,depart,worklen,wage)"+"VALUES（‘Tom1’,'321','M','china','Personnel','3','3000'）");通过调用Statement对象的executeQuery()方法进行数据的查询，而查询结果会得到ResultSet对象，ResultSet表示执行查询数据库后返回的数据的集合，ResultSet对象具有可以指向当前数据行的指针。通过该对象的next()方法，使得指针指向下一行，然后将 数据以列号或者字段名取出。如果当next()方法返回null,则表示下一行中没有数据存在。使用示例代码如下：ResultSet resultSet = statement.executeQuery("select * from staff");
6. 关闭数据库连接。使用完数据库或者不需要访问数据库时，通过Connection的close（）方法及时关闭连接。

SpringJDBC使用示例

创建数据库表（person）

CREATE TABLE 'user' (
    'id' int(11) NOT NULL auto_increment,
    'name' varchar(255) default NULL,
    'age' int(11) default NULL,
    'sex' varchar(255) default NULL,
    PRIMARY KEY ('id')
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

创建数据库表对应的po类

public class Person {  
    private String id;  
    private String name;  
    private String sex;  
    private int age;   
    //省略set get方法  
}  

创建表与实体之间的映射

public class PersonRowMapper implements RowMapper<Person>{  
    @Override  
    public Person mapRow(ResultSet rs, int rowNum) throws SQLException {  
        Person person=new Person();  
        person.setAge(rs.getInt("age"));  
        person.setName(rs.getString("name"));  
        person.setId(rs.getString("id"));  
        person.setSex(rs.getString("sex"));  
        return person;  
    }  
}  

创建数据库操作接口

public interface PersonService {  
    public void save(Person person);  
    public List<Person> getPersons();  
}  
public class PersonServiceImpl implements PersonService {  
    private JdbcTemplate jdbcTemplate;  
    public void setJdbcTemplate(DataSource dataSource) {  
        this.jdbcTemplate = new JdbcTemplate(dataSource);  
    }  
    public void save(Person p) {  
        jdbcTemplate.update("insert in to person(person_id,name,age,sex,come_from) values(?,?,?,?,?)",   
                new Object[]{p.getId(),p.getName(),p.getAge(),p.getSex()},   
                new int[]{Types.VARCHAR,Types.VARCHAR,Types.INTEGER,Types.VARCHAR});  
    }  
    public List<Person> getPersons(){  
        List<Person> list=jdbcTemplate.query("select * from person", new PersonRowMapper());  
        return list;  
    }  
}  

创建spring配置文件

<?xml version="1.0" encoding="UTF-8"?>  
<beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
　　　　　　http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">  
     <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">   
         <property name="driverClassName" value="com.mysql.jdbc.Driver"/>  
         <property name="url" value="jdbc:mysql://localhost:3306/test"/>  
         <property name="username" value="root"/>  
         <property name="password" value="123456"/>  
         <!-- 连接池启动时候的初始连接数 -->  
         <property name="initialSize" value="10"/>  
         <!-- 最小空闲值 -->  
         <property name="minIdle" value="5"/>  
         <!-- 最大空闲值 -->  
         <property name="maxIdle" value="20"/>  
         <property name="maxWait" value="2000"/>  
         <!-- 连接池最大值 -->  
         <property name="maxActive" value="50"/>  
         <property name="logAbandoned" value="true"/>  
         <property name="removeAbandoned" value="true"/>  
         <property name="removeAbandonedTimeout" value="180"/>  
    </bean>  
    <!-- 配置业务bean -->  
    <bean id="personService" class="***.PersonServiceImpl">  
        <!-- 向dataSource注入数据源 -->  
        <property name="jdbcTemplate" ref="dataSource"/>   
    </bean>  
</beans>  

测试类

public class JdbcTest {  
    public static void main(String[] args) {  
        ApplicationContext context=new ClassPathXmlApplicationContext("classpath:bean.xml");  
        PersonService service=(PersonService) context.getBean("personService");  
        System.out.println(service.getPersons().size());  
    }  
}