AI 助理
备案控制台
开发者社区 数据库 文章 正文

使用spring jdbc template简化jdbc数据库操作实例代码

2013-09-30 2424
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

文章地址: http://blog.csdn.net/5iasp/article/details/12206793

作者： javaboy2012
Email：yanek@163.com
qq:    1046011462

 

使用spring jdbc template简化jdbc数据库操作实例代码

 

包括如下几个类：

 

1. DAO接口

 

package com.test;

import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;

public interface DAO {
	
	public int getCount(String sql);
	
	public String getResultValue(String sql, String column);

	public List getResult(String sql);

	public void update(String sql);
	public void update(String sql,Object[] params);

	public void delete(String sql);
	
	public JdbcTemplate getJt();

}


2. DAO接口实现类 DAOImpl

package com.test;

import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.support.rowset.SqlRowSet;

public class DAOImpl implements  DAO{


	protected final Log log = LogFactory.getLog(this.getClass());
	
	private JdbcTemplate jt;


	public int getCount(String sql) {
		int count = 0;
		try {
			count = jt.queryForInt(sql);
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
		return count;
	}
	
	public String getResultValue(String sql, String column) {
		String value = "";
		try {
			SqlRowSet s = jt.queryForRowSet(sql);
			while (s.next()){
				value = s.getString(column);
			}
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
		return value;
	}

	public List getResult(String sql) {
		List list = null;
		try {
			list = jt.queryForList(sql);
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
		return list;
	}

	public void update(String sql) {

		try {
			jt.update(sql);
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
	}

	public void delete(String sql) {
		try {
			jt.execute(sql);
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
	}



	@Override
	public void update(String sql, Object[] params) {
		// TODO Auto-generated method stub
		try {
			jt.update(sql,params);
		} catch (DataAccessException e) {
			log.info("!!!!!!!!!!!!!!!!!!!Exception:" + e);
		}
	}

	public void setJt(JdbcTemplate jt) {
		this.jt = jt;
	}
	
	public JdbcTemplate getJt() {
		return jt;
	}

}


3. UserManager 接口

package com.test;

import java.util.List;
import java.util.Map;



public interface UserManager {
	
	
	
	
	public void addUser(String name);
	
	public void updateUser(String name,int id);
	
	public void deleteUser(int id);
	
	public String getUser(int id);
	
	public User getUserByID(int id);

	
	public List getUsers();
	
	public List<User> getUserList();

	
	public void init();
	

}


4. UserManagerImpl：UserManager 接口实现类

 

package com.test;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.core.RowMapper;



public class UserManagerImpl implements UserManager {
	
	
	private DAO dao;

	/**
	 * @param args
	 */
	public static void main(String[] args) {


	}
	
	public void addUser(String name)
	{
		/*
		String sql="insert into t_test(name) values('"+name+"')";
		dao.update(sql);
		*/
		String sql="insert into t_test(name) values(?)";
		Object[] params = new Object[] {name};
		dao.update(sql, params);
		
	}
	
	public List getUsers()
	{
		String sql = "select * FROM t_test";
		List<Map> lists = dao.getResult(sql);
		return lists;
	}
	

	public DAO getDao() {
		return dao;
	}

	public void setDao(DAO dao) {
		this.dao = dao;
	}

	@Override
	public void init() {
		// TODO Auto-generated method stub
		
	}

	@Override
	public void updateUser(String name, int id) {
		/*
		String sql="update t_test set name='"+name+"' where id="+id;
		dao.update(sql);
		*/
		/*
		String sql="update t_test set name=? where id="+id;
		Object[] params = new Object[] {name};
		*/
		String sql="update t_test set name=? where id=?";
		Object[] params = new Object[] {name,new Integer(id)};
		dao.update(sql, params);
		
		
	}

	@Override
	public void deleteUser(int id) {
		String sql="delete from t_test where id="+id;
		dao.delete(sql);
		
	}

	@Override
	public String getUser(int id) {
		// TODO Auto-generated method stub
		String sql="select name from t_test where id="+id;
		String name=dao.getResultValue(sql, "name");
		return name;
	}
	
	@Override
	public User getUserByID(int id) {

		User user=null;
		String sql="select id,name from t_test where id="+id;
		
		List<Map> lists = dao.getResult(sql);
		if (lists.size()>0)
		{
			user=new User();
			Map map=lists.get(0);
			user.setId((Integer)map.get("id"));
			user.setName((String)map.get("name"));
		}
		return user;
	}

	@Override
	public List<User> getUserList() {
		String sql = "select * FROM t_test";
		List<Map> lists = dao.getResult(sql);
		List<User> users=new ArrayList<User>();
		if (lists.size()>0)
		{
			for(int i=0;i<lists.size();i++)
			{
				User user=new User();
				Map map=lists.get(i);
				user.setId((Integer)map.get("id"));
				user.setName((String)map.get("name"));
				users.add(user);
			}
		}
		
		return users;
	
	}
	
	

}


5. User类：实体类

package com.test;

public class User {
	
	private String name;
	private int id;
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	
	
	
	

}


6. SpringUtil　：　工具类

 

package com.test;

import java.util.List;
import java.util.Map;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
 * spring工具类
 * @author 
 *
 */
public class SpringUtil {

	/**
	 * @param args
	 */
	public static void main(String[] args) {

		UserManager um=	(UserManager)SpringUtil.getBean("userManager");
		List<Map> users=um.getUsers();
		for(int i=0;i<users.size();i++)
		{
			String t_id=users.get(i).get("id").toString();
			String t_name=users.get(i).get("name").toString();
			System.out.println(t_id+"-"+t_name);
		}

	}

	private static ApplicationContext ctx = new ClassPathXmlApplicationContext(
			"applicationContext.xml");

	public static Object getBean(String beanName) {
		return ctx.getBean(beanName);
	}

}


7. 测试类： Test

 

package com.test;

import java.util.List;
import java.util.Map;

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

public class Test {

	/**
	 * @param args
	 */
	public static void main(String[] args) {

		/*
		ApplicationContext ctx = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
		UserManager um=(UserManager)ctx.getBean("userManager");
		*/
		
		UserManager um=	(UserManager)SpringUtil.getBean("userManager");
		
		//新增
		/*
		String name="test";
		um.addUser(name);
		*/
		
		//列表
		List<Map> users=um.getUsers();
		for(int i=0;i<users.size();i++)
		{
			String t_id=users.get(i).get("id").toString();
			String t_name=users.get(i).get("name").toString();
			System.out.println(t_id+"-"+t_name);
		}
		
		
		//修改
		//um.updateUser("test6", 6);
		
		//删除
		//um.deleteUser(1);
		
		//获取某个字段
		//String name2=um.getUser(2);
		//System.out.println(name2+"-"+name2);
		
		// 获取对象列表
		List<User> users2=um.getUserList();
		for(int i=0;i<users2.size();i++)
		{
			int t_id2=users2.get(i).getId();
			String t_name2=users2.get(i).getName();
			System.out.println(t_id2+"-"+t_name2);
		}
		
		//获取对象
		User u=um.getUserByID(2);
		System.out.println(u.getId()+"-"+u.getName());

	}

}


8.  Spring 配置文件：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>
	<!-- DB -->
	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
		<property name="driverClassName">
			<value>com.mysql.jdbc.Driver</value>
		</property>
		<property name="url">
			<value>jdbc:mysql://127.0.0.1/myweb?useUnicode=true&characterEncoding=gbk</value>
		</property>
		<property name="username">
			<value>root</value>
		</property>
		<property name="password">
			<value>root</value>
		</property>
	</bean>
	
	
	<bean id="jdbcTemplate"
        class="org.springframework.jdbc.core.JdbcTemplate" abstract="false"
        lazy-init="false" autowire="default" dependency-check="default">
        <property name="dataSource">
            <ref bean="dataSource" />
        </property>
    </bean>

    

	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
	</bean>
	
	<bean id="springDAOProxy"                               
          class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"> 
        <property name="proxyInterfaces"> 
            <list>
                <value>com.test.DAO</value>
            </list>
        </property>
        <property name="target"> 
            <ref bean="DAO"/> 
        </property> 
        <property name="transactionManager"> 
            <ref bean="transactionManager"/> 
        </property> 
        <property name="transactionAttributes"> 
            <props> 
                <prop key="insert*">PROPAGATION_REQUIRED</prop>
                <prop key="update*">PROPAGATION_REQUIRED</prop>
                <prop key="delete*">PROPAGATION_REQUIRED</prop> 
            </props> 
        </property>        
    </bean> 

	<bean id="DAO" class="com.test.DAOImpl">
		<property name="jt">
          <ref bean="jdbcTemplate" />
       </property>
	</bean>
	
    <bean name="userManager" class="com.test.UserManagerImpl" init-method="init">
            <property name="dao">
                    <ref bean="DAO" />
            </property>
    </bean>
        

</beans>

 

9. web环境下调用：


web.xml配置：

 

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" 
	xmlns="http://java.sun.com/xml/ns/javaee" 
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
	http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
	
	<listener>
		<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
	</listener>
	
	<context-param>
		<param-name>contextConfigLocation</param-name>
		<param-value>/WEB-INF/classes/applicationContext.xml</param-value>
	</context-param>
	
	
	
	
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
</web-app>


测试jsp文件：

 

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ page import="org.springframework.web.context.WebApplicationContext"%>
<%@ page import="com.test.*"%>
<%@ page import="org.springframework.web.context.support.WebApplicationContextUtils"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>



<%

WebApplicationContext ctx = WebApplicationContextUtils.getWebApplicationContext(this.getServletContext());
UserManager um = (UserManager) ctx.getBean("userManager");


 %>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
    
    <title>spring jdbc test</title>
	<meta http-equiv="pragma" content="no-cache">
	<meta http-equiv="cache-control" content="no-cache">
	<meta http-equiv="expires" content="0">    
	<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
	<meta http-equiv="description" content="This is my page">
	<!--
	<link rel="stylesheet" type="text/css" href="styles.css">
	-->
  </head>
  
  <body>
<br>

<%
		List<User> users2=um.getUserList();
		for(int i=0;i<users2.size();i++)
		{
			int t_id2=users2.get(i).getId();
			String t_name2=users2.get(i).getName();
			%>
			<%=t_id2 %>-<%=t_name2 %> <br>
			<%
			System.out.println(t_id2+"-"+t_name2);
		}

 %>



  </body>
</html>


 

 
资源下载地址(不需要下载积分)：http://download.csdn.net/detail/5iasp/6344527

 

 

 

文章标签：
SQL
Java
数据库连接
Spring
数据库
前端开发
关系型数据库
MySQL
数据格式
XML
关键词：
Spring数据库
数据库代码
数据库实例
Spring代码
Spring实例
javaboy2012
目录
相关文章
东方睿赢
|
4月前
|
Java 关系型数据库 数据库连接
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
东方睿赢
53 8
一位隐者
|
25天前
|
Java 关系型数据库 数据库连接
使用 Spring Boot 执行数据库操作：全面指南
使用 Spring Boot 执行数据库操作：全面指南
一位隐者
91 1
java冯坚持
|
2月前
|
Java 关系型数据库 MySQL
springboot学习四：springboot链接mysql数据库，使用JdbcTemplate 操作mysql
这篇文章是关于如何使用Spring Boot框架通过JdbcTemplate操作MySQL数据库的教程。
java冯坚持
85 0
springboot学习四：springboot链接mysql数据库，使用JdbcTemplate 操作mysql
何雨晨
|
2月前
|
Java 数据库 数据安全/隐私保护
Spring 微服务提示：使用环境变量抽象数据库主机名
Spring 微服务提示：使用环境变量抽象数据库主机名
何雨晨
49 1
nanshaws
|
2月前
|
SQL Java 数据库
Springboot+spring-boot-starter-data-jdbc实现数据库的操作
本文介绍了如何使用Spring Boot的spring-boot-starter-data-jdbc依赖来操作数据库，包括添加依赖、配置数据库信息和编写基于JdbcTemplate的数据访问代码。
nanshaws
214 2
Codelinghu
|
2月前
|
SQL druid Java
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
Codelinghu
75 0
东方睿赢
|
4月前
|
SQL Java 数据库连接
JDBC之旅：从陌生到熟悉的Java数据库连接之路
JDBC之旅：从陌生到熟悉的Java数据库连接之路
东方睿赢
33 9
龙大吉
|
4月前
|
SQL Java 数据库连接
Java开发者必知：JDBC连接数据库的“三大法宝”
Java开发者必知：JDBC连接数据库的“三大法宝”
龙大吉
44 7
栈江湖
|
1天前
|
存储 Oracle 关系型数据库
数据库传奇：MySQL创世之父的两千金My、Maria
《数据库传奇：MySQL创世之父的两千金My、Maria》介绍了MySQL的发展历程及其分支MariaDB。MySQL由Michael Widenius等人于1994年创建，现归Oracle所有，广泛应用于阿里巴巴、腾讯等企业。2009年，Widenius因担心Oracle收购影响MySQL的开源性，创建了MariaDB，提供额外功能和改进。维基百科、Google等已逐步替换为MariaDB，以确保更好的性能和社区支持。掌握MariaDB作为备用方案，对未来发展至关重要。
栈江湖
10 3
栈江湖
|
1天前
|
安全 关系型数据库 MySQL
MySQL崩溃保险箱：探秘Redo/Undo日志确保数据库安全无忧！
《MySQL崩溃保险箱：探秘Redo/Undo日志确保数据库安全无忧！》介绍了MySQL中的三种关键日志：二进制日志（Binary Log）、重做日志（Redo Log）和撤销日志（Undo Log）。这些日志确保了数据库的ACID特性，即原子性、一致性、隔离性和持久性。Redo Log记录数据页的物理修改，保证事务持久性；Undo Log记录事务的逆操作，支持回滚和多版本并发控制（MVCC）。文章还详细对比了InnoDB和MyISAM存储引擎在事务支持、锁定机制、并发性等方面的差异，强调了InnoDB在高并发和事务处理中的优势。通过这些机制，MySQL能够在事务执行、崩溃和恢复过程中保持
栈江湖
13 3

热门文章

最新文章

  • 1
    SpringMvc+Spring+MyBatis 基于注解整合
  • 2
    Spring Cloud Gateway + Nacos 实现服务上下线无缝切换
  • 3
    spring入门
  • 4
    [Spring]支持注解的Spring调度器
  • 5
    定义全局异常处理器 | 带你读《SpringBoot实战教程》之十三
  • 6
    【小家Spring】Redis序列化、RedisTemplate序列化方式大解读，介绍Genericjackson2jsonredisserializer序列化器的坑（下）
  • 7
    【Spring Boot 快速入门】十一、Spring Boot集成AutoGenerator代码生成器
  • 8
    Spring基础笔记
  • 9
    Spring Aware容器感知技术
  • 10
    Current O2 support for analyzing Spring MVC
  • 1
    云原生一体化数据库技术是一个具有潜力的领域
    115
  • 2
    构建高性能数据库的秘诀
    96
  • 3
    新一代数据库技术：融合AI的智能数据管理系统
    332
  • 4
    新一代数据库技术：融合人工智能与分布式系统的未来前景
    356
  • 5
    使用 Python 访问数据库的基本方法
    70
  • 6
    数据库解决方案
    103
  • 7
    mysql 设置环境变量与未设置环境变量连接数据库的区别
    165
  • 8
    服务器Linux系统配置mysql数据库主从自动备份
    215
  • 9
    SQLite数据库介绍以及安装
    104
  • 10
    sprinboot+vue集成neo4j图数据库
    178

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • 数据库及SQL/MySQL基础
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版
  • 2022 DTCC-阿里云一站式数据库上云最佳实践

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • 自建数据库迁移到云数据库
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
    • 下一篇
    【案例实战】SpringBoot整合阿里云文件上传OSS