java--DBUtils資料庫操作工具包
O-R Mapping簡介
什麼是O-R Mapping
Object(物件)來對映Ralation(關係,表)
常用O-R Mapping對映工具
Hibernate
Commons DbUtils(只是對JDBC簡單封裝)
簡介
commons-dbutils 是 Apache 組織提供的一個開源 JDBC工具類庫，它是對JDBC的簡單封裝，學習成本極低，並且使用dbutils能極大簡化jdbc編碼的工作量，同時也不會影響程式的效能。因此dbutils成為很多不喜歡hibernate的公司的首選。
API介紹：
org.apache.commons.dbutils.QueryRunner
org.apache.commons.dbutils.ResultSetHandler
工具類
org.apache.commons.dbutils.DbUtils、。
DbUtils類
提供如關閉連線、裝載JDBC驅動程式等常規工作的工具類，裡面的所有方法都是靜態的。主要方法如下：
public static void close(…) throws java.sql.SQLException： DbUtils類提供了三個過載的關閉方法。這些方法檢查所提供的引數是不是NULL，如果不是的話，它們就關閉Connection、Statement和ResultSet。
public static void closeQuietly(…): 這一類方法不僅能在Connection、Statement和ResultSet為NULL情況下避免關閉，還能隱藏一些在程式中丟擲的SQLEeception。
public static void commitAndCloseQuietly(Connection conn)： 用來提交連線，然後關閉連線，並且在關閉連線時不丟擲SQL異常。
public static boolean loadDriver(java.lang.String driverClassName)：這一方裝載並註冊JDBC驅動程式，如果成功就返回true。使用該方法，你不需要捕捉這個異常ClassNotFoundException。
QueryRunner類
該類簡單化了SQL查詢，它與ResultSetHandler組合在一起使用可以完成大部分的資料庫操作，能夠大大減少編碼量。
QueryRunner類提供了兩個構造方法：
預設的構造方法
需要一個 javax.sql.DataSource 來作引數的構造方法。
QueryRunner類的主要方法
public Object query(Connection conn, String sql, Object[] params, ResultSetHandler rsh) throws SQLException：執行一個查詢操作，在這個查詢中，物件陣列中的每個元素值被用來作為查詢語句的置換引數。該方法會自行處理 PreparedStatement 和 ResultSet 的建立和關閉。
public Object query(String sql, Object[] params, ResultSetHandler rsh) throws SQLException: 幾乎與第一種方法一樣；唯一的不同在於它不將資料庫連線提供給方法，並且它是從提供給構造方法的資料來源(DataSource) 或使用的setDataSource 方法中重新獲得 Connection。
public Object query(Connection conn, String sql, ResultSetHandler rsh) throws SQLException : 執行一個不需要置換引數的查詢操作。
public int update(Connection conn, String sql, Object[] params) throws SQLException:用來執行一個更新（插入、更新或刪除）操作。
public int update(Connection conn, String sql) throws SQLException：用來執行一個不需要置換引數的更新操作。
ResultSetHandler介面
該介面用於處理 java.sql.ResultSet，將資料按要求轉換為另一種形式。
ResultSetHandler 介面提供了一個單獨的方法：Object handle (java.sql.ResultSet .rs)
ResultSetHandler 介面的實現類
ArrayHandler：把結果集中的第一行資料轉成物件陣列。
ArrayListHandler：把結果集中的每一行資料都轉成一個數組，再存放到List中。
BeanHandler：將結果集中的第一行資料封裝到一個對應的JavaBean例項中。
BeanListHandler：將結果集中的每一行資料都封裝到一個對應的JavaBean例項中，存放到List裡。
ColumnListHandler：將結果集中某一列的資料存放到List中。
KeyedHandler(name)：將結果集中的每一行資料都封裝到一個Map裡，再把這些map再存到一個map裡，其key為指定的key。
MapHandler：將結果集中的第一行資料封裝到一個Map裡，key是列名，value就是對應的值。
MapListHandler：將結果集中的每一行資料都封裝到一個Map裡，然後再存放到List。
c3p0-config.xml,必須放在src目錄下 f’be’r’sfbers
<c3p0-config>
<!-- 預設配置，如果沒有指定則使用這個配置 -->
<default-config>
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">
<![CDATA[jdbc:mysql://127.0.0.1:3306/mydb?useUnicode=true&characterEncoding=UTF-8]]>
</property>
<property name="user">root</property>
<property name="password">1234</property>
<!-- 初始化池大小 -->
<property name="initialPoolSize">2</property>
<!-- 最大空閒時間 -->
<property name="maxIdleTime">30</property>
<!-- 最多有多少個連線 -->
<property name="maxPoolSize">10</property>
<!-- 最少幾個連線 -->
<property name="minPoolSize">2</property>
<!-- 每次最多可以執行多少個批處理語句 -->
<property name="maxStatements">50</property>
</default-config>
<!-- 命名的配置 -->
<named-config name="hncu">
<property name="driverClass">com.mysql.jdbc.Driver</property>
<property name="jdbcUrl">
<![CDATA[jdbc:mysql://127.0.0.1:3306/hncu?useUnicode=true&characterEncoding=UTF-8]]>
</property>
<property name="user">root</property>
<property name="password">1234</property>
<property name="acquireIncrement">5</property><!-- 如果池中資料連線不夠時一次增長多少個 -->
<property name="initialPoolSize">10</property>
<property name="minPoolSize">3</property>
<property name="maxPoolSize">10</property>
<property name="maxStatements">0</property>
<property name="maxStatementsPerConnection">5</property> <!-- he's important, but there's only one of him -->
</named-config>
</c3p0-config>
package cn.hncu.pubs;
import java.sql.Connection;
import javax.sql.DataSource;
import com.mchange.v2.c3p0.ComboPooledDataSource;
public class C3p0Utils {
//本地執行緒管理物件，用於實現: 同一個執行緒獲取的連線是同一個
private static ThreadLocal<Connection> t = new ThreadLocal<Connection>();
// private static ComboPooledDataSource pool = null;
private static DataSource pool = null;
static{
try {
// pool=new ComboPooledDataSource();//使用預設配置項
pool=new ComboPooledDataSource("hncu");
} catch (Exception e) {
e.printStackTrace();
}
}
public static DataSource getDataSource(){
return pool;
}
public static Connection getConn() {
//先從t中拿，如果有就拿出去，如果沒有再到池中拿且把該物件放到t中
Connection con = t.get();
if(con==null){
try {
con=pool.getConnection();
t.set(con); //放到t中
} catch (Exception e) {
throw new RuntimeException(e.getMessage(), e);
}
}
System.out.println("獲取一個連線:"+con);
return con;
}
}
值物件
Stud.java
package cn.hncu.domain;
public class Stud {
private String name;
private String id;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
@Override
public String toString() {
return "Stud [name=" + name + ", id=" + id + "]";
}
}
Person.java
package cn.hncu.domain;
public class Person {
private String id;
private String name;
// private String addr;//取出的address為null
private String address;//這裡必須和資料庫的欄位名一樣,版本Person2會解決這一點
private int age;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
return address;
}
public void setAddress(String address) {
this.address = address;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "Person [id=" + id + ", name=" + name + ", address=" + address
+ ", age=" + age + "]";
}
}
Person2.java
package cn.hncu.domain;
import org.apache.commons.dbutils.ext.Column;
public class Person2 {
private String id;
private String name;
@Column(value="address")//添加註解
private String addr;
private Integer age;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
return addr;
}
public void setAddress(String addr) {
this.addr = addr;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
@Override
public String toString() {
return "Person [id=" + id + ", name=" + name + ", addr=" + addr
+ ", age=" + age + "]";
}
}
Person3.java
package cn.hncu.domain;
import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.Table;
@Table(value="person")
public class Person3 {
@Column
private String id;
@Column
private String name;
@Column(value="address")
private String addr;
@Column
private Integer age;
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAddress() {
return addr;
}
public void setAddress(String addr) {
this.addr = addr;
}
public Integer getAge() {
return age;
}
public void setAge(Integer age) {
this.age = age;
}
@Override
public String toString() {
return "Person [id=" + id + ", name=" + name + ", addr=" + addr
+ ", age=" + age + "]";
}
}
Stud2.java
package cn.hncu.domain;
import org.apache.commons.dbutils.ext.Column;
import org.apache.commons.dbutils.ext.Table;
@Table(value="stud")
public class Stud2 {
@Column
private String name;
@Column
private String id;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
@Override
public String toString() {
return "Stud [name=" + name + ", id=" + id + "]";
}
}
DBUtils
package cn.hncu.dbUtilsDemo;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;
import cn.hncu.domain.Stud;
import cn.hncu.pubs.C3p0Utils;
public class dbUtilsHello {
@Test
public void dbQuery() throws Exception{
Connection con=C3p0Utils.getConn();
String sql="select * from stud";
List<Stud> studs=new ArrayList<Stud>();
ResultSet rs=con.createStatement().executeQuery(sql);
while(rs.next()){
Stud stud=new Stud();
stud.setId(rs.getString(1));
stud.setName(rs.getString(2));
studs.add(stud);
}
System.out.println(studs);
rs.close();
con.close();
}
@Test
public void dbQueryByDbUtils() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
String sql="select * from Stud";
List<Stud> studs=run.query(sql, new BeanListHandler<Stud>(Stud.class));
System.out.println(studs);
}
}
package cn.hncu.dbUtilsDemo;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ext.ExtQueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.commons.dbutils.handlers.MapListHandler;
import org.junit.Test;
import cn.hncu.domain.Person;
import cn.hncu.domain.Person2;
import cn.hncu.domain.Person3;
import cn.hncu.domain.Stud2;
import cn.hncu.pubs.C3p0Utils;
public class dbUtilsDemo {
/**
* 演示:增、刪、改 和 事務
*
*/
// INSERT, UPDATE, or DELETE ----用run.update()方法
@Test//增,刪,改 ---同理
public void save() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
//引數寫死的---Statement的方式
// String sql="insert into stud values('sdsad','sds')";//傳參寫死了
// run.update(sql);
//引數寫活的---PreparedStatement的方式---注意，引數和佔位符要對應給出，否則會出錯
String sql="insert into person(id,name,address,age) values(?,?,?,?)";//傳參寫活
run.update(sql, "A002","張三","湖南益陽",24);
run.update("insert into person(id,name,address) values(?,?,?)","A003","趙子龍","湖南益陽");
}
//事務的演示 ---通過在呼叫run.update()時給同一個con物件來實現回滾
@Test
public void saveTx() throws Exception{
QueryRunner run=new QueryRunner();//做事務，這裡不用給引數，而是在下面直接給con物件
Connection con=C3p0Utils.getConn();
String sql_1="insert into person values(?,?,?,?)";
String sql_2="insert into person values('A005','rose','America',46)";//提交事務
// String sql_2="insert into person values('A002','rose','America',46)";//回滾事務
try {
con.setAutoCommit(false);
run.update(con, sql_1, "A010","Jack","英國",14);
run.update(con, sql_2);
con.commit();
System.out.println("提交一個事務...");
} catch (SQLException e) {
con.rollback();
System.out.println("回滾一個事務...");
}finally{
con.setAutoCommit(true);
con.close();
}
}
/**
* 查詢
*/
@Test//把查詢資料封裝成: MapList--事務,修改(用代理簡單),只查詢(用dbUtils簡單)
public void query_1() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
String sql="select * from person";
List<Map<String, Object>> persons=run.query(sql, new MapListHandler());
System.out.println(persons);
}
@Test//把查詢資料封裝成: BeanList--事務,修改(用代理簡單),只查詢(用dbUtils簡單)
public void query_2() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
String sql="select * from person";
List<Person> persons=run.query(sql, new BeanListHandler<Person>(Person.class));
System.out.println(persons);
}
@Test//當表字段名和值物件的屬性名不一致時，解決方案:第一步,在sql語句中用表字段的別名
public void query_3() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
// String sql="select id, name, address addr,age from person";//不可行
String sql="select id, name, address,age from person";//給addr欄位添加註解@Column(value="address")
List<Person2> persons=run.query(sql, new BeanListHandler<Person2>(Person2.class));
System.out.println(persons);
}
@Test//帶條件的查詢(帶引數)
public void query_4() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
// String sql="select id, name, address addr,age from person where name like '%a%' and age>20";
String sql="select * from person where name like ? and age>?";
List<Person> persons=run.query(sql, new BeanListHandler<Person>(Person.class),"%A%",20);
System.out.println(persons);
}
/**
* 批處理
*/
@Test
public void batch_1() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
// CREATE TABLE student(
// id VARCHAR(32) PRIMARY KEY,
// NAME VARCHAR(30)
// );
String sql="insert into student values(?,?)";
for(int i=1;i<=100;i++){
//100次批處理，每次批處理包含3條sql語句(params[][]的行數代表sql語句的條數，列數代表每條sql中引數的個數)
String params[][]={{"D001"+i,"AAA"+i},{"D003"+i,"BBB"+i},{"D004"+i,"CCC"+i}};
run.batch(sql, params);
}
}
@Test//該方法專用於給資料分頁專案新增測試資料
public void batch_2() throws Exception{
QueryRunner run=new QueryRunner(C3p0Utils.getDataSource());
// CREATE TABLE student(
// id int PRIMARY KEY,
// NAME VARCHAR(30)
// );
String sql="insert into student values(?,?)";
for(int i=1;i<=100;i++){
Object[][] params ={ { i,"QQQQQ"+i},{500+i,"TTTTT"+i},{800+i,"WWWWW"+i}};
run.batch(sql, params);
}
}
/////////////////以下演示擴充套件包中的功能--ExtQueryRunner/////////////////////
@Test
public void query_5(){
//OR對映功能 ---不用sql語句，直接用Object(物件)來對映Ralation(關係,表) 查詢 ,
//但是值物件要新增@Table、@Id、@Column等註解(實現Hibernate中對映檔案的功能)
ExtQueryRunner eRun=new ExtQueryRunner(C3p0Utils.getDataSource());
List<Person3> persons=eRun.query(Person3.class);
System.out.println(persons);
}
@Test
public void save_2(){
ExtQueryRunner eRun=new ExtQueryRunner(C3p0Utils.getDataSource());
Stud2 stud=new Stud2();//添加註解@Table(value="stud")和@Column
stud.setId("sadsa");
stud.setName("xxxxzzzzmmmmm");
eRun.save(stud);
}
}
相關推薦
java--DBUtils資料庫操作工具包
O-R Mapping簡介 什麼是O-R Mapping Object(物件)來對映Ralation(關係,表) 常用O-R Mapping對映工具 Hibernate Commons DbUtils(只是對JDBC簡單封裝) 簡介 common
java：陣列操作工具類 java.util.Arrays包 主要方法詳解
轉載自：https://www.cnblogs.com/dengyungao/p/7525067.html java：陣列操作工具類 java.util.Arrays包 主要方法詳解 Arrays類位於Java.util包下，是一個對陣列操作的工具類，現將Arrays類中的方法做一個總結（J
JAVA 資料庫操作工具類----mysql
封裝了一個JAVA操作mysql的工具類，如果有需要的，可以直接使用。 1、MysqlHelper類，包括對資料庫的CRUD操作,其中查詢有單記錄返回和多記錄返回。另外，我使用了反射封裝類，希望和大家多多交流。 /** * 資料庫操作類，包括增刪改查 *
【java】http請求工具包
package com.ruoyi.common.utils.http; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.Input
對JAVA資原始檔操作工具類
package com.kkmall.risk.common.utils; import java.io.IOException; import java.io.InputStream; import java.io.UnsupportedEncodingException; import jav
使用Java實現動態代理工具包
import java.lang.reflect.InvocationHandler; import java.lang.reflect.Method; import java.lang.reflect.Proxy; public class ProxyFactory { private
AWS SDK for Java 的使用（適用於 Java 的 AWS 開發工具包開發人員指南）之配置aws憑證
今天接了個新專案，使用的AWS SDK for Java。例如： <dependency> <groupId>com.amazonaws</groupId> <artifactId>
Java併發程式設計-併發工具包java.util.concurrent使用指南
譯序 1. java.util.concurrent - Java併發工具包 Java 5 添加了一個新的包到 Java 平臺，java.util.concurrent 包。這個包包含有一系列能夠讓 Java 的併發程式設計變得更加簡單輕鬆的類。在這
適用於 Java 的AWS 開發工具包_AWS SDK工具包資源
Amazon S3 客戶端資料加密 這個易用的客戶端加密機制可幫助提高儲存在 Amazon S3 中的應用程式資料的安全性。因為加密和解密是在客戶端執行，所以私有金鑰絕不會離開該應用程式。 Amazon Dyn
Java 連線資料庫的工具類
用jdbc連線mysql資料庫的工具類：做到連線資料庫，只需要修改配置檔案的資料庫名，自己資料庫的使用者名稱和密碼，其他不用修改，測試類已經寫好。需要的jar包：junit-4.7.jar 和jdbc的驅動包：自己在網上可以免費下載一：java程式碼package cn.lu
java連線資料庫操作2--防止sql注入
sql注入 概念 所謂sql注入，即使用者輸入的字串和我們的sql結合產生預判之外的結果，比如下面這段判斷使用者名稱密碼是否正確的程式碼 String sql = "SELECT * FROM use
java.util.concurrent 併發工具包(二)
一、ThreadPoolExecutor 執行緒池執行者 初始化執行緒池的引數 corePoolSize 核心執行緒大小 maximumPoolSize 最大執行緒大小 keepAliveTime 空餘的多餘執行緒保持時間 unit 時間
資料庫操作工具-QueryRunner
在相繼學習了JDBC和資料庫操作之後，我們明顯感到編寫JDBC程式碼並非一件輕鬆的事兒。為了幫助我們更高效的學習工作，從JDBC的繁重程式碼中解脫出來，老佟給我們詳盡介紹了一個簡化JDBC操作的元件——DBUtils。我們今天主要學習了它所提供的兩個類和一
MySQL解壓版本安裝及Navicat資料庫操作工具安裝
一、MySQL的下載 2，解壓下載檔案到你想要安裝MySQL的路徑。 二、MySQL的安裝 1，命令安裝。使用cd命令到解壓目錄，使用：mysqld -install安裝MySQL。 2，建立data目錄，使用命令：mysqld --initialize-in
java web資料庫操作
這是自己初期學習java mvc模式時整理的jdbc連線資料庫的程式碼，資料庫為mysql ConnDB是基礎類，封裝了連線資料庫需要的一些資訊。 package com.hsp.model; im
XML —— Java 操作 XML 工具包（ JDOM&DOM4J ）
1. JDOM 引入 JDOM 是一種使用 XML（標準通用標記語言下的一個子集） 的獨特 Java 工具包，用於快速開發 XML 應用 程式。 集合DOM 和 SAX 的優點 需要引入jar包 JDOM 官方網站：http://www.jdom.org/ 小缺陷：
Stoker的Java學習之封裝資料庫連線工具類與commons-dbutils
Java學習之封裝資料庫連線工具類與commons-dbutils 一.封裝資料庫連結工具類 public class JDBCUitl { // 宣告連結 private static Connection connection; // 註冊驅動 st
Java IO操作--壓縮包zip實現工具類
壓縮檔案大致可以分為三種：ZIP、JAR、GZ。 壓縮流 在日常的使用中經常會使用到像WinRAR或WinZIP這樣的壓縮檔案，通過這些軟體可以把一個很大的檔案進行壓縮以方便傳輸。 在JAVA中 為了減少傳輸時的資料量也提供了專門的壓縮流，可以將檔案或資料夾壓縮成ZI
Java操作檔案工具包
package cn.lk.Utils; import java.io.BufferedReader; import java.io.File; import java.io.FileReader;
Java利用fastdfs-client-java開發工具包操作FastDFS分散式檔案系統
org.csource.common.MyException: getStoreStorage fail, errno code: 2 at org.csource.fastdfs.StorageClient.newWritableStorageConnection(StorageClient.java:1