spring开发_Spring_DataSource

项目结构：

http://www.cnblogs.com/hongten/gallery/image/112745.html

/spring_2100_spring_dataSource/src/com/b510/db/SpringDataSource.java

package com.b510.db;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;
import javax.sql.DataSource;

import com.b510.domain.Person;

public class SpringDataSource {

    private DataSource dataSource;

    public DataSource getDataSource() {
        return dataSource;
    }

    @Resource
    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    /**
     * 保存一条记录
     * 
     * @param p
     *            Person的一个实例对象
*/
    public void save(Person p) {
        String sql = "insert into person(name,age,sex)values(" + "'"
                + p.getName() + "'" + "," + "'" + p.getAge() + "'" + "," + "'"
                + p.getSex() + "'" + ")";
        Connection conn = null;
        try {
            conn = dataSource.getConnection();
            Statement statement = conn.prepareStatement(sql);
            statement.executeUpdate(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 获取所有记录
     * 
     * @return 返回一个list对象
*/
    public List<Person> getPerson() {
        String sql = "select * from person";
        Connection conn = null;
        List<Person> list = new ArrayList<Person>();
        try {
            conn = dataSource.getConnection();
            Statement statement = conn.prepareStatement(sql);
            ResultSet rs = statement.executeQuery(sql);
            Person person = null;
            while (rs.next()) {
                person = new Person();
                person.setId(rs.getInt("id"));
                person.setName(rs.getString("name"));
                person.setAge(rs.getInt("age"));
                person.setSex(rs.getString("sex"));
                list.add(person);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return list;
    }
}

/spring_2100_spring_dataSource/src/com/b510/domain/Person.java

package com.b510.domain;

import org.springframework.stereotype.Component;

/**
 * Person实体类
 * 
 * @author Hongten
 * 
 */
@Component
public class Person implements java.io.Serializable {

    // Fields

    /**
     * 版本号
*/
    private static final long serialVersionUID = -47270870639923184L;
    /**
     * id号
*/
    private Integer id;
    /**
     * 姓名
*/
    private String name;
    /**
     * 年龄
*/
    private Integer age;
    /**
     * 性别
*/
    private String sex;

    // Constructors

    /** default constructor */
    public Person() {
    }

    /** minimal constructor */
    public Person(String name) {
        this.name = name;
    }

    /** full constructor */
    public Person(String name, Integer age, String sex) {
        this.name = name;
        this.age = age;
        this.sex = sex;
    }

    // Property accessors

    public Integer getId() {
        return this.id;
    }

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

    public String getName() {
        return this.name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return this.age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public String getSex() {
        return this.sex;
    }

    public void setSex(String sex) {
        this.sex = sex;
    }

}

/spring_2100_spring_dataSource/src/com/b510/test/SpringTest.java

package com.b510.test;

import java.util.List;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.b510.db.SpringDataSource;
import com.b510.domain.Person;

public class SpringTest {

    /**
     * @param args
*/
    public static void main(String[] args) {
        ApplicationContext act = new ClassPathXmlApplicationContext("bean.xml");
        SpringDataSource sds = (SpringDataSource) act.getBean("sds");
        Person person = new Person("hw", 20, "M");
        sds.save(person);

        List<Person> list = sds.getPerson();
        for (Person p : list) {
            System.out.println("id=" + p.getId() + ",name=" + p.getName()
                    + ",age=" + p.getAge() + ",sex=" + p.getSex());
        }
    }

}

/spring_2100_spring_dataSource/src/bean.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd">
    <context:annotation-config />

    <!-- 读取jdbc.properties配置文件 -->
    <context:property-placeholder location="classpath:jdbc.properties" />

    <!-- 配置数据源 -->
    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="${driverClassName}" />
        <property name="url" value="${url}" />
        <property name="username" value="${username}" />
        <property name="password" value="${password}" />
        <!-- 连接池启动时的初始值 -->
        <property name="initialSize" value="${initialSize}" />
        <!-- 连接池的最大值 -->
        <property name="maxActive" value="${maxActive}" />
        <!-- 最大空闲值.当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接慢慢释放一部分，一直减少到maxIdle为止 -->
        <property name="maxIdle" value="${maxIdle}" />
        <!--  最小空闲值.当空闲的连接数少于阀值时，连接池就会预申请去一些连接，以免洪峰来时来不及申请 -->
        <property name="minIdle" value="${minIdle}" />
    </bean>

    <bean id="sds" class="com.b510.db.SpringDataSource"></bean>
</beans>

/spring_2100_spring_dataSource/src/jdbc.properties

driverClassName=org.gjt.mm.mysql.Driver
url=jdbc\:mysql\://localhost\:3307/spring?useUnicode\=true&characterEncoding\=UTF-8
username=root
password=root
initialSize=1
maxActive=300
maxIdle=2
minIdle=1

 运行结果：

2012-3-14 17:23:22 org.springframework.context.support.AbstractApplicationContext prepareRefresh
信息: Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@1a05308: display name [org.springframework.context.support.ClassPathXmlApplicationContext@1a05308]; startup date [Wed Mar 14 17:23:22 CST 2012]; root of context hierarchy
2012-3-14 17:23:22 org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions
信息: Loading XML bean definitions from class path resource [bean.xml]
2012-3-14 17:23:22 org.springframework.context.support.AbstractApplicationContext obtainFreshBeanFactory
信息: Bean factory for application context [org.springframework.context.support.ClassPathXmlApplicationContext@1a05308]: org.springframework.beans.factory.support.DefaultListableBeanFactory@74c3aa
2012-3-14 17:23:22 org.springframework.core.io.support.PropertiesLoaderSupport loadProperties
信息: Loading properties file from class path resource [jdbc.properties]
2012-3-14 17:23:22 org.springframework.beans.factory.support.DefaultListableBeanFactory preInstantiateSingletons
信息: Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@74c3aa: defining beans [org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.beans.factory.config.PropertyPlaceholderConfigurer#0,dataSource,sds]; root of factory hierarchy
id=2,name=hanyuan,age=21,sex=男
id=3,name=hongten,age=21,sex=男
id=4,name=hongten,age=21,sex=男
id=5,name=hello,age=12,sex=M
id=6,name=hongten,age=12,sex=M
id=7,name=hongten2,age=12,sex=M
id=8,name=hw,age=20,sex=M