文档章节

使用dbutils对mysql数据库做增删改查的基本操作方法

孟飞阳
 孟飞阳
发布于 2016/06/20 11:12
字数 469
阅读 94
收藏 1

1、数据库名:phoenix_uml,t_user.sql 表结构

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for t_user
-- ----------------------------
DROP TABLE IF EXISTS `t_user`;
CREATE TABLE `t_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `createDate` datetime DEFAULT NULL,
  `nickName` varchar(255) DEFAULT NULL,
  `password` varchar(255) DEFAULT NULL,
  `userName` varchar(255) NOT NULL,
  `userType` int(11) NOT NULL,
  `groupId` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `userName` (`userName`),
  KEY `FKCB63CCB65064113` (`groupId`),
  CONSTRAINT `FKCB63CCB65064113` FOREIGN KEY (`groupId`) REFERENCES `t_user_group` (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8;

2、jdbc.properties,位于工程的根目录

driverClassName = com.mysql.jdbc.Driver
password = root
username = root
url = jdbc:mysql://localhost:3306/phoenix_uml?useUnicode=true&characterEncoding=utf8

3、dbutils的测试方法

package demo14;

import java.io.FileInputStream;
import java.math.BigInteger;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;
import org.apache.commons.dbcp.DataSourceConnectionFactory;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.ScalarHandler;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

/**
 * 本例中使用的jar包名称及版本:Commons-dbutils-1.6.jar,commons-dbcp-1.2.1.jar,commons-pool-1.6.jar
 * 
 * 本例演示了如何使用dbutils对数据库内容做增删改查的基本操作
 * @author mengfeiyang
 *
 */
public class DBUtilsTest {
	Connection conn = null;
	DataSource ds = null;
	@Before
	public void test() throws Exception {
		/**获取dataSource的三种方法**/
		//方法一:
/*		ds = new BasicDataSource();
		ds.setDriverClassName("com.mysql.jdbc.Driver");
		ds.setUrl("jdbc:mysql://localhost:3306/phoenix_uml?useUnicode=true&characterEncoding=utf8");
		ds.setUsername("root");
		ds.setPassword("root");*/
		
		Properties pro = new Properties();
		//方法二:
/*		pro.setProperty("driverClassName", "com.mysql.jdbc.Driver");
		pro.setProperty("url", "jdbc:mysql://localhost:3306/phoenix_uml?useUnicode=true&characterEncoding=utf8");
		pro.setProperty("username", "root");
		pro.setProperty("password", "123"); */
		
		//方法3:
		pro.load(new FileInputStream("jdbc.properties"));
		ds = BasicDataSourceFactory.createDataSource(pro);//通过properties得到DataSource
		DataSourceConnectionFactory dsc = new DataSourceConnectionFactory(ds);
		conn = dsc.createConnection();
	}
	@Test
	public void testQuery() throws SQLException{
		QueryRunner qrunner = new QueryRunner();
		UserModel u = qrunner.query(conn,"select * from t_user where id=?", new BeanHandler<UserModel>(UserModel.class),1);
		System.out.println(u.getNickName()+"\t"+u.getUserName()+"\t"+u.getPassword());
	}
	
	@Test
	public void testQueryList() throws SQLException{
		QueryRunner qrunner = new QueryRunner();
		List<UserModel> list = qrunner.query(conn,"select * from t_user", new BeanListHandler<UserModel>(UserModel.class));
		for(UserModel u : list){
			System.out.println(u.getNickName()+"\t"+u.getUserName()+"\t"+u.getPassword());
		}
	}
	
	@Test
	public void testUpdateOrDelete() throws SQLException{
		QueryRunner qrunner = new QueryRunner();
		qrunner.update(conn,"update t_user set nickName='张三三' where id=2");
	}
	
	@Test
	public void testAdd() throws SQLException{
		QueryRunner qrunner = new QueryRunner();
		qrunner.insert(conn,"insert into t_user values(?,?,?,?,?,?,?);", new BeanHandler<UserModel>(UserModel.class), new Object[]{0,null,"马六",123,"ml",0,2});
		BigInteger newId = (BigInteger) qrunner.query(conn, "select last_insert_id()", new ScalarHandler<BigInteger>(1));  
		UserModel u = qrunner.query(conn, "select * from t_user where id=?",new BeanHandler<UserModel>(UserModel.class),newId);
		System.out.println(u.getNickName()+"\t"+u.getUserName()+"\t"+u.getPassword());
	}
	
	@After
	public void after(){
		DbUtils.closeQuietly(conn);
	}
}

 

© 著作权归作者所有

共有 人打赏支持
孟飞阳
粉丝 205
博文 964
码字总数 543203
作品 5
朝阳
个人站长
day14_DBUtils学习笔记

一、DBUtils介绍 Apache公司开发的框架。   DBUtils是java编程中的数据库操作实用工具,小巧简单实用。   DBUtils封装了对JDBC的操作,简化了JDBC操作。可以少写代码。 commons-dbutils 是...

黑泽明军
05/20
0
0
JDBC读取MySQL的BLOB类型

今天写了个SQL查数据库,需要根据id分组,然后将同一分组中某几列的值都平铺开来,网络上查了下,MySQL中的 GROUP_CONCAT 函数,还是很好用的,SQL 大致写成如下: select , GROUPCONCAT(con...

Breath_L
2012/06/21
0
3
Python下访问MYSQL的方法总结

在Python下做过服务器开发的小伙伴对ORM技术一定都不陌生,ORM(Object-Relational Mapping),将关系数据库的表结构映射到对象上,隐藏了数据库操作背后的细节,简化了对数据操作的写法,使...

zwgdft
2016/10/15
0
0
使用元数据+反射优化CURD操作+DBUtils

元数据的使用 1)想取得对数据库相关信息的描述,可以元数据 2)DatabaseMetaData/DatabaseMetaData dbmd = conn.getMetaData() 3)ParameterMetaData/ParameterMetaData psmd = pstmt.getPara......

chenruibing
2015/06/16
0
0
Commons DbUtils

1 概述 Commons DBUtils类库是小型的设计于易于使用JDBC的类集合。JDBC资源清理是平凡的,容易出错,以至于这些类从你的代码中抽象出清理代码,剩下你最初真正想要使用JDBC做的代码:查询和更...

Leech
2015/07/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

js 操作cookie

var cookie = {// 设置cookie方法set:function(key, val, time){// 获取当前时间var date = new Date();// 将date设置为n天以后的时间var expiresDays = time;//...

小丶二
23分钟前
1
0
限制root远程登录 su和sudo命令

9月21日任务 3.7 su命令 3.8 sudo命令 3.9 限制root远程登录 对于Linux而言,权限的重要性毋庸置疑!对于普通用户而言无法执行那些只有root用户才能有效的命令,导致工作无法有效进行; 系统...

robertt15
25分钟前
2
0
MQTT协议的初浅认识之通讯级别和持久会话

背景 这是我最近了解MQTT协议的最后一部分内容了,MQTT协议里面的QOS和Keep Alive是两个比较重要的内容。QOS的设置,直接影响了订阅客户端与中间件之间的消息交互行为。而Keep Alive直接影响...

亚林瓜子
27分钟前
1
0
calc

width: calc(100% - 30px); 特别注意:减号左右空格,均不能去掉。 width: calc(100% - 30px);

柴高八斗之父
35分钟前
1
0
Spring Cloud Gateway全局过滤器GlobalFilter:返回消息和重定向

Spring Cloud Gateway的全局过滤器GlobalFilter,顾名思义,声明后会对所有的请求生效,可以用来做权限控制,这里简单记录一下拦截到非法请求后如何返回自定义信息和将请求重定向到指定URL。...

夜雨寄北09
37分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部