亚洲鲁丝片AV无码多人_ 使用Spring JDBC包裝基本的CRUD操作

想起來(lái)Spring的JDBC還不錯，就拿起來(lái)研究了一下，順便也寫(xiě)了個(gè)小例子，希望對初學(xué)者有點(diǎn)用處

主要注意以下幾點(diǎn)：
1. 對于一些特定的小項目中，很多的工作量都在增刪改上，而這些代碼當然是驚人地相似，所以對5個(gè)簡(jiǎn)單的
方法抽象了一下，以達到共用的目的
2. 主要文件：applicationContext.xml, BaseDAO.java, BaseDAOImp.java, DAORowMapper.java
3. 在BaseDAOImp.java里有一個(gè)Main方法可以做測試
4. DB中只要一個(gè)表，表名：users, 三個(gè)列：id(int,主鍵)，name(varchar), email(varchar)

這只是一個(gè)初稿，后面再做修改再與大家分享

applicationContext.xml

代碼

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="userDAO" class="com.xxxxx.dao.BaseDAOImp" singleton="false">
<property name="jdbcTemplate">
<ref bean="jdbcTemplate" />
</property>
<property name="tableName" value="users"></property>
<property name="objectClass" value="com.xxxxx.admin.vo.UserVO"></property>
<property name="keyColumn" value="id"></property>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<constructor-arg>
<ref bean="datasource" />
</constructor-arg>
</bean>
<bean id="datasource"
class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName"
value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />
<property name="url" value="jdbc:sqlserver://localhost;databaseName=testdb" />
<property name="username" value="sa" />
<property name="password" value="admin" />
</bean>
</beans>

BaseDAO.java

代碼

package com.xxxxx.dao;
import java.util.List;
public interface BaseDAO {
public int insert(Object obj);
public int update(Object obj);
public int delete(Object id);
public Object findByID(Object id);
public List findAll();
}

BaseDAOImp.java

代碼

package com.xxxxx.dao;
import java.util.List;
import org.springframework***ans.factory.xml.XmlBeanFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.jdbc.core.JdbcTemplate;
import com.xxxxx.admin.vo.UserVO;
import com.xxxxx.common.utils.SQLUtils;
public class BaseDAOImp implements BaseDAO {
private JdbcTemplate jdbcTemplate;
private String tableName;
private Class objectClass;
private String keyColumn;
public void setKeyColumn(String keyColumn) {
this.keyColumn = keyColumn;
}
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public void setObjectClass(Class objectClass) {
this.objectClass = objectClass;
}
public void setTableName(String tableName) {
this.tableName = tableName;
}
public int delete(Object id) {
String sql = "delete from " + tableName + " where "+keyColumn+"=?";
return jdbcTemplate.update(sql, new Object[]{id});
}
public List findAll() {
String sql = "select * from " + tableName;
return jdbcTemplate.query(sql, new DAORowMapper(objectClass));
}
public Object findByID(Object id) {
String sql = "select * from " + tableName + " where " + keyColumn + "=?";
return jdbcTemplate.queryForObject(sql, new Object[]{id}, new DAORowMapper
(objectClass));
}
/*
* 這里用的Database的主鍵自增策略，如果想自己實(shí)現可以去看看Hibernate的主鍵生成方法
* 其實(shí)簡(jiǎn)單一點(diǎn)可以在server起來(lái)的時(shí)候定義一個(gè)存放主鍵的Map,然后讓這些主鍵值遞增就可以了
，
* 只是要注意一下并發(fā)問(wèn)題
*/
public int insert(Object obj) {
Object[] sqlAndParams = SQLUtils.generateInsert(obj, tableName);
return jdbcTemplate.update((String)sqlAndParams[0], (Object[])sqlAndParams[1]);
}
public int update(Object obj) {
Object[] sqlAndParams = SQLUtils.generateUpdate(obj, tableName, keyColumn);
return jdbcTemplate.update((String)sqlAndParams[0], (Object[])sqlAndParams[1]);
}
public static void main(String[] args){
// init factory:
XmlBeanFactory factory = new XmlBeanFactory(new ClassPathResource
("applicationContext.xml"));
BaseDAO userDAO = (BaseDAO)factory.getBean("userDAO");
// find all
List list = userDAO.findAll();
System.out.println("user count: "+list.size());
// find by id
UserVO userVO = (UserVO)userDAO.findByID(new Integer(2));
System.out.println("Ginger‘s Email: "+userVO.getEmail());
// insert
userVO = new UserVO();
userVO.setName("tester1");
userVO.setEmail("tester@gmail.com");
Object insertResult = userDAO.insert(userVO);
System.out.println("insert returned: "+insertResult);
//update
userVO = new UserVO();
userVO.setId(new Integer(3));
userVO.setName("tester33");
userVO.setEmail("tester33@gmail.com");
Object updateResult = userDAO.update(userVO);
System.out.println("update returned: "+updateResult);
//delete
Object deleteResult = userDAO.delete(new Integer(4));
System.out.println("delete returned: "+deleteResult);
}
}

DAORowMapper.java

代碼

package com.xxxxx.dao;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.rowset.ResultSetWrappingSqlRowSetMetaData;
import com.xxxxx.common.utils.ReflectionUtils;
public class DAORowMapper implements RowMapper {
private Class rowObjectClass;
public DAORowMapper(Class rowObjectClass){
this.rowObjectClass = rowObjectClass;
}
public Object mapRow(ResultSet rs, int index) throws SQLException {
Object object;
try {
object = rowObjectClass.newInstance();
} catch (Exception e) {
throw new RuntimeException(e);
}
ResultSetWrappingSqlRowSetMetaData wapping = new
ResultSetWrappingSqlRowSetMetaData(rs.getMetaData());
for(int i=1;i<=wapping.getColumnCount();i++){
String name = wapping.getColumnName(i);
Object value = rs.getObject(i);
ReflectionUtils.setFieldVlaue(object, name, value);
}
return object;
}
}

欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久

使用Spring JDBC包裝基本的CRUD操作