Java开发之Spring连接数据库方法实例分析
本文实例讲述了Java开发之Spring连接数据库方法。分享给大家供大家参考,具体如下:
接口:
packagecn.com.service; importjava.util.List; importcn.com.bean.PersonBean; publicinterfacePersonService{ //保存 publicvoidsave(PersonBeanperson); //更新 publicvoidupdate(PersonBeanperson); //获取person publicPersonBeangetPerson(intid); publicList<PersonBean>getPersonBean(); //删除记录 publicvoiddelete(intpersonid); }
PersonBean类:
packagecn.com.bean; publicclassPersonBean{ privateintid; privateStringname; publicPersonBean(Stringname){ this.name=name; } publicintgetId(){ returnid; } publicvoidsetId(intid){ this.id=id; } publicStringgetName(){ returnname; } publicvoidsetName(Stringname){ this.name=name; } }
接口实现:
packagecn.com.service.impl; importjava.util.List; importjavax.sql.DataSource; importorg.springframework.jdbc.core.JdbcTemplate; importcn.com.bean.PersonBean; importcn.com.service.PersonService; publicclassPersonServiceImplimplementsPersonService{ privateJdbcTemplatejdbcTemplate; publicvoidsetDataSource(DataSourcedataSource){ this.jdbcTemplate=newJdbcTemplate(dataSource); } @Override publicvoidsave(PersonBeanperson){ //TODOAuto-generatedmethodstub jdbcTemplate.update("insertintoperson(name)values(?)",newObject[]{person.getName()}, newint[]{java.sql.Types.VARCHAR}); } @Override publicvoidupdate(PersonBeanperson){ //TODOAuto-generatedmethodstub jdbcTemplate.update("updatepersonsetname=?whereid=?",newObject[]{person.getName(),person.getId()}, newint[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER}); } @Override publicPersonBeangetPerson(intid){ //TODOAuto-generatedmethodstub return(PersonBean)jdbcTemplate.queryForObject("select*frompersonwhereid=?",newObject[]{id}, newint[]{java.sql.Types.INTEGER},newPersonRowMapper()); } @SuppressWarnings("unchecked") @Override publicList<PersonBean>getPersonBean(){ //TODOAuto-generatedmethodstub return(List<PersonBean>)jdbcTemplate.query("select*fromperson", newPersonRowMapper()); } @Override publicvoiddelete(intpersonid){ //TODOAuto-generatedmethodstub jdbcTemplate.update("deletefrompersonwhereid=?",newObject[]{personid}, newint[]{java.sql.Types.INTEGER}); } }
RowMapper:
packagecn.com.service.impl; importjava.sql.ResultSet; importjava.sql.SQLException; importorg.springframework.jdbc.core.RowMapper; importcn.com.bean.PersonBean; publicclassPersonRowMapperimplementsRowMapper{ @Override publicObjectmapRow(ResultSetrs,intindex)throwsSQLException{ //TODOAuto-generatedmethodstub PersonBeanperson=newPersonBean(rs.getString("name")); person.setId(rs.getInt("id")); returnperson; } }
beans.xml配置
<?xmlversion="1.0"encoding="UTF-8"?> <beansxmlns="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/contexthttp://www.springframework.org/schema/context/spring-context-2.5.xsd http://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop-2.5.xsd http://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx-2.5.xsd "> <!--<context:property-placeholderlocation="classpath:jdbc.properties"/>--> <beanid="dataSource"class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close"> <propertyname="driverClassName"value="com.mysql.jdbc.Driver"/> <propertyname="url"value="jdbc:mysql://localhost:3306/wy"/> <propertyname="username"value="root"/> <!--property池启动时的初始值--> <propertyname="password"value="123"/> <!--连接name="initialSize"value="${initialSize}"/>--> <propertyname="initialSize"value="1"/> <!--连接池的最大值--> <propertyname="maxActive"value="500"/> <!--最大空闲值.当经过一个高峰时间后,连接池可以慢慢将已经用不到的连接慢慢释放一部分,一直减少到maxIdle为止--> <propertyname="maxIdle"value="2"/> <!--最小空闲值.当空闲的连接数少于阀值时,连接池就会预申请去一些连接,以免洪峰来时来不及申请--> <propertyname="minIdle"value="1"/> </bean> <beanid="txManager"class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <propertyname="dataSource"ref="dataSource"/> </bean> <tx:annotation-driventransaction-manager="txManager"/> <beanid="personService"class="cn.com.service.impl.PersonServiceImpl"> <propertyname="dataSource"ref="dataSource"></property> </bean> </beans>
测试类:
packageJunit.test; importstaticorg.junit.Assert.*; importorg.junit.BeforeClass; importorg.junit.Test; importorg.springframework.context.ApplicationContext; importorg.springframework.context.support.ClassPathXmlApplicationContext; importcn.com.bean.PersonBean; importcn.com.service.PersonService; publicclassPersonTest2{ privatestaticPersonServicepersonService; @BeforeClass publicstaticvoidsetUpBeforeClass()throwsException{ ApplicationContextact=newClassPathXmlApplicationContext("beans.xml"); personService=(PersonService)act.getBean("personService"); } @Test publicvoidsave(){ personService.save(newPersonBean("wyy")); } @Test publicvoidupdate(){ PersonBeanperson=personService.getPerson(1); person.setName("wy"); personService.update(person); } @Test publicvoidgetPerson(){ PersonBeanperson=personService.getPerson(1); System.out.println(person.getName()); } @Test publicvoiddelete(){ personService.delete(1); } }
数据库:
CreateTable CREATETABLE`person`( `id`int(11)NOTNULLauto_increment, `name`varchar(10)NOTNULL, PRIMARYKEY(`id`) )ENGINE=InnoDBAUTO_INCREMENT=2DEFAULTCHARSET=utf8
希望本文所述对大家Java程序设计有所帮助。