Java 使用 Dbutils 工具类库 操作mysql
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Java 使用 Dbutils 工具类库 操作mysql，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6124字，纯文字阅读大概需要9分钟。
内容图文
package JDBCDemo;
2
3 import java.sql.SQLException;
4 import java.util.ArrayList;
5 import java.util.HashMap;
6 import java.util.List;
7 import java.util.Map;
8
9 import javax.xml.bind.annotation.W3CDomHandler;
10
11 import org.apache.commons.dbutils.DbUtils;
12 import org.apache.commons.dbutils.QueryRunner;
13 import org.apache.commons.dbutils.handlers.ArrayHandler;
14 import org.apache.commons.dbutils.handlers.ArrayListHandler;
15 import org.apache.commons.dbutils.handlers.BeanHandler;
16 import org.apache.commons.dbutils.handlers.BeanListHandler;
17 import org.apache.commons.dbutils.handlers.ColumnListHandler;
18 import org.apache.commons.dbutils.handlers.MapHandler;
19 import org.apache.commons.dbutils.handlers.MapListHandler;
20 import org.apache.commons.dbutils.handlers.ScalarHandler;
21
22 import com.mysql.jdbc.Connection;
23
24 public class dbutilsdemo1 {
25 private static Connection connection = JDBCUtils.getConnection();
26 private static QueryRunner qRunner = new QueryRunner();
27 public static void main(String[] args) {
28 try {
29 //insert();
30 //delete();
31 //ArraryHandlerdemo();
32 // beanListHandlerDemo();
33 //ColumnListHandlerDemo();
34 //mapHandlerDemo();
35 mapListHandlerDemo();
36 } catch (Exception e) {
37 // TODO: handle exception
38 System.out.println(e);
39 }
40
41 }
42 public static void insert() throws SQLException {
43 //insert delete update
44 String sql = "insert into zhangwu (name,money) values (?,?);";
45 Object[] object = {"打麻将支出",100};
46 int row = qRunner.update(connection,sql,object);
47 DbUtils.closeQuietly(connection);
48 if (row>0) {
49 System.out.println("插入数据成功");
50 }else {
51 System.out.println("插入数据失败");
52 }
53
54 }
55
56 public static void update() throws SQLException {
57 String sql = "update zhangwu set money=? where id=?;";
58 Object[] object = {500,4};
59 int row = qRunner.update(connection,sql,object);
60 DbUtils.closeQuietly(connection);
61 if (row>0) {
62 System.out.println("修改数据成功");
63 }else {
64 System.out.println("修改数据失败");
65 }
66 }
67
68 public static void delete() throws SQLException {
69 String sql = "delete from zhangwu where id=?;";
70 Object[] object = {100};
71 int row = qRunner.update(connection,sql,object);
72 DbUtils.closeQuietly(connection);
73 if (row>0) {
74 System.out.println("删除数据成功");
75 }else {
76 System.out.println("删除数据失败");
77 }
78 }
79
80 public static void ArraryHandlerdemo () throws SQLException {
81 //返回1条数据集
82 //ArraryHandler
83 String sql = "select * from zhangwu;";
84 Object[] res = qRunner.query(connection, sql, new ArrayHandler());
85 for(Object object : res) {
86 System.out.print(object+"\t");
87 }
88
89 }
90 public static void ArraryListHandlerDemo() throws SQLException {
91 //返回整个数据集
92 String sql = "select * from zhangwu;";
93 List<Object[]> res = qRunner.query(connection, sql, new ArrayListHandler());
94 for(Object[] objs : res) {
95 for(Object oo : objs) {
96 System.out .print(oo + "\t");
97 }
98 System.out.println("");
99 }
100 }
101 public static void beanHandler() throws SQLException {
102 //返回1条数据集
103 String sql = "select * from zhangwu;";
104 Zhangwu zw = qRunner.query(connection,sql,new BeanHandler<Zhangwu>(Zhangwu.class));
105 System.out.println(zw);
106 }
107 public static void beanListHandlerDemo() throws SQLException{
108 //返回整个数据集
109 String sql = "select * from zhangwu;";
110 List<Zhangwu> zwlist= qRunner.query(connection, sql, new BeanListHandler<Zhangwu>(Zhangwu.class));
111 for(Zhangwu zwchild : zwlist) {
112 System.out.println(zwchild.toString());
113 }
114 }
115 public static void ColumnListHandlerDemo() throws SQLException {
116 //单列结果查询
117 String sql = "select distinct name from zhangwu";
118 List<Object> zwlist= qRunner.query(connection, sql, new ColumnListHandler<Object>("name"));
119 for(Object zwchild : zwlist) {
120 System.out.println(zwchild.toString());
121 }
122 }
123 public static void scalarHandlerDemo() throws SQLException {
124 //单结果集查询
125 String sql = "select count(*) from zhangwu;";
126 Long num = qRunner.query(connection, sql, new ScalarHandler<Long>());
127 System.out.println(num);
128 }
129 public static void mapHandlerDemo() throws SQLException {
130 //结果集第一行数据 封装到map集合中
131 String sql = "select * from zhangwu;";
132 Map< String,Object > map= qRunner.query(connection,sql,new MapHandler());
133 for(String key : map.keySet()) {
134 System.out.println(key + "..." + map.get(key));
135 }
136 }
137 public static void mapListHandlerDemo() throws SQLException {
138 // 封装到map集合中 适合少量数据
139 String sql = "select * from zhangwu;";
140 List<Map<String, Object>> listmap = qRunner.query(connection, sql, new MapListHandler());
141 for(Map<String, Object> mapchild : listmap) {
142 for(String key : mapchild.keySet()) {
143 System.out.print(key + " = " + mapchild.get(key) + " ");
144 }
145 System.out.println("");
146 }
147 }
148 }
Java 使用 Dbutils 工具类库 操作mysql
标签：string span tco etl get private lex sys cat
本文系统来源：http://www.cnblogs.com/wwcherish/p/8037705.html
内容总结
以上是互联网集市为您收集整理的Java 使用 Dbutils 工具类库 操作mysql全部内容，希望文章能够帮你解决Java 使用 Dbutils 工具类库 操作mysql所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】