歡迎您光臨本站 註冊首頁

淺談JDBC的概念理解與學習

←手機掃碼閱讀     火星人 @ 2014-03-09 , reply:0

JDBC的概念:doMaim對象(javaBean實體)

UserDao(DataAccessObject)

工廠模式,Factory消除UserDaoTest業務類對具體實現UserDaoJdbc類的依賴

讀配置文件,通過工廠讀配置文件來載入信息,具體實現類使用工廠來獲取實現介面類的對象

JDBC的概念:工廠一般使用單例模式

工廠-->生產產品(Dao這個產品)

類載入器,不光可以load.class,還可以load其他的文件

事務概念與處理

1.原子性:不能拆分,組成事事務處理的語句形成一個邏輯處理單元,不能只執行其中的一部分

2.一致性:事務做完之後,保定數據的完整性約束

3.隔離性:一個事務處理對另一個事務處理的影響

4.持續性:事務處理的結果能被永久保存下來

步驟:打開事務connection.setAutoCommit(false);

提交事務:connection.commit();

回滾事務:connection.rollback();

jdbc預設是自動提交的,客戶端連接也是自動提交的,要想打開事務,要把自動提交關掉

保存點:savePoint

Savepointsp=null

sp=conn.setSavepoint();

conn.rollback(sp);

-----------------------------------

JDBC的概念:跨多個資料庫的事務JTA

JTA容器weblogic,websphere

分成兩階段提交.

用到JNDI伺服器

javax.transaction.UserTransactiontx=

(UserTransaction)ctx.lookup("jndiName");

tx.begin();

//connection1connection2(可能來自不同的資料庫)

tx.commit();//tx.rollback();

---------------------------------

事務的隔離級別:

connction.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

隔離級別

讀未提交(Readuncommitted)可能出現臟讀,不可重複讀,幻讀

讀已提交(Readcommitted)可能出現不可重複讀,幻讀

可重複讀(Repeatableread)可能出現幻讀(幻影數據,執行插入一條數據,在另一個客戶端有可能看到)

可串列化(Serializable)

隔離級別各個資料庫的實現是不一樣的.

--------------------------------------------------

關於存儲過程(兩層架構的時候用的很多)

三層架構的系統很少使用了.略過不看了先.

---------------------------------------------------

其他幾個有用的API

jdbc3.0規範提供的方法

插一條記錄,它能把主鍵返回來

PreparedStatement.getGeneratedKeys();

PreparedStatementps=connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);

ps.executeUpdate();

ResultSetrs=st.getGeneratedKeys();

rs.getInt(1);

批量處理:可以大幅提升大量增刪改的速度(並非絕對),與具體資料庫有關,也不一定能提高性能

PreparedStatement.addBatch();

PreparedStatement.executeBatch();

-------------------------------------------------------------

可滾動結果集與分頁特性

Statementst=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

ResultSet.TYPE_SCROLL_SENSITIVE--對資料庫敏感的,就是說,資料庫中記錄發生了變化,結果集會覺察到(但某些資料庫不一定遵循這一規範,mysql就不遵循)

ResultSet.CONCUR_UPDATABLE--可更新的,就是說,改變結果集中的內容可以影響到資料庫里

ResultSet.CONCUR_READ_ONLY--只讀的,

可滾動的結果集

Statementst=connection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

ResultSetrs=st.executeQuery(sql);

rs.beforeFirst();

rs.afterLast();

rs.first();

rs.isFirst();

rs.last();

rs.isLast();

rs.absolute(9);

rs.moveToInsertRow();

conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);

rs.updateString("colname","newvalue");

rs.updateRow();

mysql分頁例如:

selectid,name,money,birthdayfromuserlimit150,10;

從user表中第150條記錄開始,取10條記錄

---------------------------------------------------------

jdbc元數據信息資料庫元數據信息、參數元數據信息

DatabaseMetaDatameta=connection.getMetaData();

通過DatabaseMetaData可以獲得資料庫相關的信息,如:

資料庫版本,資料庫名,資料庫廠商信息,是否支持事務,是否支持某種事務隔離級別,

是否支持滾動結果集等.

ParameterMetaDatapmd=preparedStatement.getParameterMetaData();

通過ParameterMetaData可以獲得參數信息.

ParameterMetaDatapmd=ps.getParameterMetaData();

intcount=pmd.getParameterCount();

System.out.println("count=" count);

for(inti=1;i<=count;i )

{

ps.setObject(i,params[i-1]);

}

ResultSetrs=ps.executeQuery();

--------------------------------------------------

dataSource代理模式:

組合優先於繼承

攔截Connection.close()方法

動態代理

調用處理器

----------------------------------------------------

數據源和連接池

DataSource用來取代DriverManger來獲取Connection

通過DataSource獲得Connection速度很快

通過DataSource獲得的Connection都是已經被包裹過的(不是驅動原來的連接),

他的close方法已經被修改

一般DataSource內部會用一個連接池來緩存Connection,這樣可以大幅度提高

資料庫的訪問速度;

連接池可以理解成一個能夠存放Connection的Connection

我們的程序只和DataSource打交道,不會直接訪問連接池.

------------------------------------------

DBCP的應用

1.載入三個.jar

2.寫dbcpconfig.properties配置文件

3.創建DataSource數據源

使用DBCP必須用的三個包

commons-dbcp-1.2.2commons-dbcp-1.2.1.jar,

spring-framework-2.5.6libjakarta-commonscommons-pool.jar,commons-collection-3.1.jar

dbcpconfig.properties

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/jdbc

username=root

password=root

#初始化連接

initialSize=10

#最大連接數量

maxActive=50

#最大空閑連接

maxIdle=20

#最小空閑連接

minIdle=5

#超時等待時間以毫秒為單位

maxWait=60000

#JDBC驅動建立連接時附帶的連接屬性格式必須為這樣:屬性名=property

#注注意user與password兩個屬性會被明確地傳遞.因此這裡不需要包含他們

connectionProperties=useUnicode=true;characterEncoding=utf-8

#指定由連接池所創建的連接的自動提交auto-commit狀態

defaultAutoCommit=true

#driverdefault指定由連接池所創建的連接的只讀read-only狀態

#如果沒有設置該值,則setReadOnly方法不被調用.

defaultReadOnly=

#driverdefault指定由連接池所創建的連接的事務級別TransactionIsolation

#可用值為下列之一:這依賴於資料庫

#NONE,READ_UNCOMMITED,READ_COMMITTED

defaultTransactionIsolation=READ_COMMITTED

----------------------------------------------------

創建數據源

Propertiesprop=newProperties();

prop.setProperty("driverClassName","com.mysql.jdbc.Driver");

prop.setProperty("url","jdbc:mysql://localhost:3306/jdbc");

prop.setProperty("username","root");

prop.setProperty("password","root");

#dbcp使用這個方法創建數據源,需要一個Property參數,參數中的鍵值對就為.properties文件中的配置

#可以直接load進來,省的寫了

Propertiesprop=newProperties();

InputStreamis=JdbcUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");

prop.load(is);

DataSourcemyDataSource=BasicDataSourceFactory.createDataSource(prop);

-------------------------------------------------------------------------

模板模式對查詢抽象,採用繼承的方式(對查詢來說,不夠靈活,查詢的列一變化,就得修改超類)

策略模式(採用介面的方式傳遞一個介面的參數,通過匿名類為各種需求實現)

-----------------------------------------------------------------------

使用JdbcTemplate工具類,在spring框架中提供了一個JdbcTemplate工具類,這個類對JDBCAPI進行了很好的封裝

這個類就像我們自己對JDBC進行封裝一樣.只是代碼列健壯,功能更強大而已.

我們以後在實際項目中可以使用JdbcTemplate類來完全替代直接使用JDBCAPI這與直接使用jdbcapi沒有太大性能區別

使用JdbcTemplate工具類需要額外從spring開發包中導入spring.jar和commons-logging.jar

關於jdbcTemplate查詢,更新相關使用方法見練習

如果想獲取connection,自由進行操作,可以使用

jdbc.execute(newConnectionCallback()
{

publicObjectdoInConnection(Connectionconn)throwsSQLException,
DataAccessException
{}
});//拿到了Connction隨你怎麼用了

-------------------------------------------------------------------
Spring的NameParameterJdbcTemplate
NameParameterJdbcTemplate內部包含了一個JdbcTemplate,JdbcTemplate能做的事情它都能做
NameParameterJdbcTemplate相對於JdbcTemplate主要增加了參數可以命名的功能

publicObjectqueryForObject(Stringsql,MapparamMap,RowMapperrowMapper)
publicObjectqueryForObject(Stringsql,SqlParameterSourceparamSource,RowMapperrowMapper

SqlParameterSource的兩個主要實現MapSqlParameterSource和BeanPropertyParameterSource

SimpleJdbcTemplate內部包含了一個NamedParameterJdbcTemplate,NamedParameterJdbcTemplate

能做的事情SimpleJdbcTemplate都能幹,SimpleJdbcTemplate相對於NamedParameterJdbcTemplate主要

增加了JDK5.0的泛型技術和可變長度參數支持

simpleJdbcTemplate中有些方法不全,比如拿到主鍵的方法就沒有,可以獲取到NamedParameterJdbcTemplate

調用它裡面的方法

getNamedParameterJdbcOperations()返回的是NamedParameterJdbcOperations其實現就是NamedParameterJdbcTemplate這個類

getJdbcOperations()返回的是JdbcOperation其實現就是JdbcTemplate

Map參數源:採用鍵值對方式傳參(參數別名可任意,如:m,:n)

staticUserfindUser(Useruser)
{
NamedParameterJdbcTemplatenamed=newNamedParameterJdbcTemplate(dataSource);
Stringsql="selectid,name,money,birthdayfromuserwheremoney>:mandid<:n";
Mapmap=newHashMap();
map.put("m",user.getMoney());
map.put("n",user.getId());
Objectu=named.queryForObject(sql,map,newBeanPropertyRowMapper(User.class));//這個方法當查詢對象多於一個或為null時會拋異常
return(User)u;
}


Bean屬性參數源使用方法(參數別名要與bean類的屬性對應,如:money,:id)(通過&號也可以命名別名,不建議使用)

staticUserfindUser(Useruser)
{
NamedParameterJdbcTemplatenamed=newNamedParameterJdbcTemplate(dataSource);
Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";
SqlParameterSourceps=newBeanPropertySqlParameterSource(user);

Objectu=named.queryForObject(sql,ps,newBeanPropertyRowMapper(User.class));//這個方法當查詢對象多於一個或為null時會拋異常
return(User)u;
} //保存數據獲得主鍵
publicintupdate(Stringsql,SqlParameterSourceparamSource,KeyHoldergeneratedKeyHolder)staticvoidaddUser(Useruser)

{

NameParameterJdbcTemplatenamed=newNameParameterJdbcTemplate(dataSource);

Stringsql="insertintouser(name,birthday,money)values(:name,:birthday,:money";

SqlParameterSourceps=newBeanPropertySqlParameterSource(user);

KeyHolderkeyHolder=newGeneratedKeyHolder();

named.update(sql,ps,keyHolder);

intid=keyHolder.getKey().intValue();user.setId(id);//如果不是整型的主鍵呢,使用Mapmap=keyHolder.getKeys();}

JDBC的概念:使用泛型技術與可變長度的參數(JDK1.5版本以上)

//泛型技術(JDK1.5以上版本可使用)
//使用泛型技術與可變長度的參數(JDK1.5版本以上)
staticUserfindUserSimple(Stringname)
{
SimpleJdbcTemplatesimple=newSimpleJdbcTemplate(JdbcUtil.getDataSource());

Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";

//用這個泛型,返回結果就不用向下轉型了
//publicTqueryForObject(Stringsql,ParameterizedRowMapperrm,Object...args)throwsDataAccessException
Useru=simple.queryForObject(sql,
ParameterizedBeanPropertyRowMapper.newInstance(
User.class),name);//這個行映射器的參數是可變長的Object...
returnu;
}


-----------------------------------------------------------------------------------------------------------------------
//代碼

importjava.util.HashMap;
importjava.util.Map;

importorg.springframework.jdbc.core.BeanPropertyRowMapper;
importorg.springframework.jdbc.core.namedparam.BeanPropertySqlParameterSource;
importorg.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
importorg.springframework.jdbc.core.namedparam.SqlParameterSource;

importcom.feihu.domain.User;
importcom.feihu.jdbc.JdbcUtil;

publicclassSimpleJdbcTemplate
{


privatestaticNamedParameterJdbcTemplatenamed=newNamedParameterJdbcTemplate(
JdbcUtil.getDataSource());

///參數命名方法查詢NamedParameterJdbcTemplate
//兩種參數傳遞方法BeanPropertySqlParameterSource(user)、MapSqlParameterSource

//bean屬性參數源
staticUserfindUser(Useruser)
{
//Bean屬性參數源使用方法(參數別名要與bean類的屬性對應,如:money,:id)(通過&號也可以命名別名,不建議使用)

Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";
SqlParameterSourceps=newBeanPropertySqlParameterSource(user);

Objectu=named.queryForObject(sql,ps,newBeanPropertyRowMapper(
User.class));//這個方法當查詢對象多於一個或為null時會拋異常
return(User)u;
}

//Map參數源
staticUserfindUser2(Useruser)
{
Stringsql="selectid,name,money,birthdayfromuserwheremoney>:mandid<:n";
Mapmap=newHashMap();
map.put("m",user.getMoney());
map.put("n",user.getId());
Objectu=named.queryForObject(sql,map,newBeanPropertyRowMapper(
User.class));//這個方法當查詢對象多於一個或為null時會拋異常
return(User)u;
}

//泛型技術(JDK1.5以上版本可使用)
//使用泛型技術與可變長度的參數(JDK1.5版本以上)
staticUserfindUserSimple(Stringname)
{
SimpleJdbcTemplatesimple=newSimpleJdbcTemplate(JdbcUtil.getDataSource());

Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";

//用這個泛型,返回結果就不用向下轉型了
//publicTqueryForObject(Stringsql,ParameterizedRowMapperrm,Object...args)throwsDataAccessException
Useru=simple.queryForObject(sql,
ParameterizedBeanPropertyRowMapper.newInstance(
User.class),name);//這個行映射器的參數是可變長的Object...
returnu;
}
}


[火星人 ] 淺談JDBC的概念理解與學習已經有804次圍觀

http://coctec.com/docs/java/show-post-61242.html