淺談JDBC的概念理解與學(xué)習(xí)
JDBC的概念：doMaim對象(javaBean實(shí)體)
UserDao(DataAccessObject)
工廠模式，F(xiàn)actory消除UserDaoTest業(yè)務(wù)類對具體實(shí)現(xiàn)UserDaoJdbc類的依賴
讀配置文件,通過工廠讀配置文件來加載信息，具體實(shí)現(xiàn)類使用工廠來獲取實(shí)現(xiàn)接口類的對象
JDBC的概念：工廠一般使用單例模式
工廠-->生產(chǎn)產(chǎn)品(Dao這個(gè)產(chǎn)品)
類加載器，不光可以load.class,還可以load其他的文件
事務(wù)概念與處理
1.原子性：不能拆分，組成事事務(wù)處理的語句形成一個(gè)邏輯處理單元，不能只執(zhí)行其中的一部分
2.一致性：事務(wù)做完之后，保定數(shù)據(jù)的完整性約束
3.隔離性：一個(gè)事務(wù)處理對另一個(gè)事務(wù)處理的影響
4.持續(xù)性：事務(wù)處理的結(jié)果能被***保存下來
步驟：打開事務(wù)connection.setAutoCommit(false);
提交事務(wù)：connection.commit();
回滾事務(wù)：connection.rollback();
jdbc缺省是自動提交的，客戶端連接也是自動提交的，要想打開事務(wù)，要把自動提交關(guān)掉
保存點(diǎn)：savePoint
Savepointsp=null
sp=conn.setSavepoint();
conn.rollback(sp);
-----------------------------------
JDBC的概念：跨多個(gè)數(shù)據(jù)庫的事務(wù)JTA
JTA容器weblogic,websphere
分成兩階段提交。
用到JNDI服務(wù)器
javax.transaction.UserTransactiontx=
(UserTransaction)ctx.lookup("jndiName");
tx.begin();
//connection1connection2(可能來自不同的數(shù)據(jù)庫)
tx.commit();//tx.rollback();
---------------------------------
事務(wù)的隔離級別：
connction.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
隔離級別
讀未提交(Readuncommitted)可能出現(xiàn)臟讀，不可重復(fù)讀，幻讀
讀已提交(Readcommitted)可能出現(xiàn)不可重復(fù)讀，幻讀
可重復(fù)讀(Repeatableread)可能出現(xiàn)幻讀(幻影數(shù)據(jù)，執(zhí)行插入一條數(shù)據(jù)，在另一個(gè)客戶端有可能看到)
可串行化(Serializable)
隔離級別各個(gè)數(shù)據(jù)庫的實(shí)現(xiàn)是不一樣的。
--------------------------------------------------
關(guān)于存儲過程(兩層架構(gòu)的時(shí)候用的很多)
三層架構(gòu)的系統(tǒng)很少使用了。略過不看了先。
---------------------------------------------------
其他幾個(gè)有用的API
jdbc3.0規(guī)范提供的方法
插一條記錄，它能把主鍵返回來
PreparedStatement.getGeneratedKeys();
PreparedStatementps=connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS);
ps.executeUpdate();
ResultSetrs=st.getGeneratedKeys();
rs.getInt(1);
批量處理：可以大幅提升大量增刪改的速度(并非絕對)，與具體數(shù)據(jù)庫有關(guān)，也不一定能提高性能
PreparedStatement.addBatch();
PreparedStatement.executeBatch();
-------------------------------------------------------------
可滾動結(jié)果集與分頁特性
Statementst=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet.TYPE_SCROLL_SENSITIVE--對數(shù)據(jù)庫敏感的，就是說，數(shù)據(jù)庫中記錄發(fā)生了變化，結(jié)果集會覺察到(但某些數(shù)據(jù)庫不一定遵循這一規(guī)范，mysql就不遵循)
ResultSet.CONCUR_UPDATABLE--可更新的，就是說，改變結(jié)果集中的內(nèi)容可以影響到數(shù)據(jù)庫里
ResultSet.CONCUR_READ_ONLY--只讀的，
可滾動的結(jié)果集
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元數(shù)據(jù)信息數(shù)據(jù)庫元數(shù)據(jù)信息、參數(shù)元數(shù)據(jù)信息
DatabaseMetaDatameta=connection.getMetaData();
通過DatabaseMetaData可以獲得數(shù)據(jù)庫相關(guān)的信息，如：
數(shù)據(jù)庫版本，數(shù)據(jù)庫名，數(shù)據(jù)庫廠商信息，是否支持事務(wù)，是否支持某種事務(wù)隔離級別，
是否支持滾動結(jié)果集等。
ParameterMetaDatapmd=preparedStatement.getParameterMetaData();
通過ParameterMetaData可以獲得參數(shù)信息.
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代理模式：
組合優(yōu)先于繼承
攔截Connection.close()方法
動態(tài)代理
調(diào)用處理器
----------------------------------------------------
數(shù)據(jù)源和連接池
DataSource用來取代DriverManger來獲取Connection
通過DataSource獲得Connection速度很快
通過DataSource獲得的Connection都是已經(jīng)被包裹過的(不是驅(qū)動原來的連接),
他的close方法已經(jīng)被修改
一般DataSource內(nèi)部會用一個(gè)連接池來緩存Connection,這樣可以大幅度提高
數(shù)據(jù)庫的訪問速度;
連接池可以理解成一個(gè)能夠存放Connection的Connection
我們的程序只和DataSource打交道，不會直接訪問連接池。
------------------------------------------
DBCP的應(yīng)用
1.加載三個(gè).jar
2.寫dbcpconfig.properties配置文件
3.創(chuàng)建DataSource數(shù)據(jù)源
使用DBCP必須用的三個(gè)包
commons-dbcp-1.2.2\commons-dbcp-1.2.1.jar,
spring-framework-2.5.6\lib\jakarta-commons\commons-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
#***連接數(shù)量
maxActive=50
#***空閑連接
maxIdle=20
#最小空閑連接
minIdle=5
#超時(shí)等待時(shí)間以毫秒為單位
maxWait=60000
#JDBC驅(qū)動建立連接時(shí)附帶的連接屬性格式必須為這樣:屬性名=property
#注注意user與password兩個(gè)屬性會被明確地傳遞。因此這里不需要包含他們
connectionProperties=useUnicode=true;characterEncoding=utf-8
#指定由連接池所創(chuàng)建的連接的自動提交auto-commit狀態(tài)
defaultAutoCommit=true
#driverdefault指定由連接池所創(chuàng)建的連接的只讀read-only狀態(tài)
#如果沒有設(shè)置該值，則setReadOnly方法不被調(diào)用。
defaultReadOnly=
#driverdefault指定由連接池所創(chuàng)建的連接的事務(wù)級別TransactionIsolation
#可用值為下列之一：這依賴于數(shù)據(jù)庫
#NONE,READ_UNCOMMITED,READ_COMMITTED
defaultTransactionIsolation=READ_COMMITTED
----------------------------------------------------
創(chuàng)建數(shù)據(jù)源
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使用這個(gè)方法創(chuàng)建數(shù)據(jù)源，需要一個(gè)Property參數(shù)，參數(shù)中的鍵值對就為.properties文件中的配置
#可以直接load進(jìn)來，省的寫了
Propertiesprop=newProperties();
InputStreamis=JdbcUtil.class.getClassLoader().getResourceAsStream("dbcpconfig.properties");
prop.load(is);
DataSourcemyDataSource=BasicDataSourceFactory.createDataSource(prop);
-------------------------------------------------------------------------
模板模式對查詢抽象，采用繼承的方式(對查詢來說，不夠靈活，查詢的列一變化，就得修改超類)
策略模式(采用接口的方式傳遞一個(gè)接口的參數(shù)，通過匿名類為各種需求實(shí)現(xiàn))
-----------------------------------------------------------------------
使用JdbcTemplate工具類，在spring框架中提供了一個(gè)JdbcTemplate工具類，這個(gè)類對JDBCAPI進(jìn)行了很好的封裝
這個(gè)類就像我們自己對JDBC進(jìn)行封裝一樣。只是代碼列健壯，功能更強(qiáng)大而已。
我們以后在實(shí)際項(xiàng)目中可以使用JdbcTemplate類來完全替代直接使用JDBCAPI這與直接使用jdbcapi沒有太大性能區(qū)別
使用JdbcTemplate工具類需要額外從spring開發(fā)包中導(dǎo)入spring.jar和commons-logging.jar
關(guān)于jdbcTemplate查詢，更新相關(guān)使用方法見練習(xí)
如果想獲取connection，自由進(jìn)行操作，可以使用
- jdbc.execute(newConnectionCallback()
- {
- publicObjectdoInConnection(Connectionconn)throwsSQLException,
- DataAccessException
- {}
- });//拿到了Connction隨你怎么用了
- -------------------------------------------------------------------
- Spring的NameParameterJdbcTemplate
- NameParameterJdbcTemplate內(nèi)部包含了一個(gè)JdbcTemplate，所以JdbcTemplate能做的事情它都能做
- NameParameterJdbcTemplate相對于JdbcTemplate主要增加了參數(shù)可以命名的功能
- publicObjectqueryForObject(Stringsql,MapparamMap,RowMapperrowMapper)
- publicObjectqueryForObject(Stringsql,SqlParameterSourceparamSource,RowMapperrowMapper)
#p#
SqlParameterSource的兩個(gè)主要實(shí)現(xiàn)MapSqlParameterSource和BeanPropertyParameterSource
SimpleJdbcTemplate內(nèi)部包含了一個(gè)NamedParameterJdbcTemplate，所以NamedParameterJdbcTemplate
能做的事情SimpleJdbcTemplate都能干，SimpleJdbcTemplate相對于NamedParameterJdbcTemplate主要
增加了JDK5.0的泛型技術(shù)和可變長度參數(shù)支持
simpleJdbcTemplate中有些方法不全，比如拿到主鍵的方法就沒有，可以獲取到NamedParameterJdbcTemplate
調(diào)用它里面的方法
getNamedParameterJdbcOperations()返回的是NamedParameterJdbcOperations其實(shí)現(xiàn)就是NamedParameterJdbcTemplate這個(gè)類
getJdbcOperations()返回的是JdbcOperation其實(shí)現(xiàn)就是JdbcTemplate
++++++++++++++++++++++++++++++++++++++++++++++++++
Map參數(shù)源：采用鍵值對方式傳參(參數(shù)別名可任意,如: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));//這個(gè)方法當(dāng)查詢對象多于一個(gè)或?yàn)閚ull時(shí)會拋異常
- return(User)u;
- }
Bean屬性參數(shù)源使用方法(參數(shù)別名要與bean類的屬性對應(yīng)，如: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));//這個(gè)方法當(dāng)查詢對象多于一個(gè)或?yàn)閚ull時(shí)會拋異常
- return(User)u;
- } //保存數(shù)據(jù)獲得主鍵
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的概念：使用泛型技術(shù)與可變長度的參數(shù)(JDK1.5版本以上)
- //泛型技術(shù)(JDK1.5以上版本可使用)
- //使用泛型技術(shù)與可變長度的參數(shù)(JDK1.5版本以上)
- staticUserfindUserSimple(Stringname)
- {
- SimpleJdbcTemplatesimple=newSimpleJdbcTemplate(JdbcUtil.getDataSource());
- Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";
- //用這個(gè)泛型，返回結(jié)果就不用向下轉(zhuǎn)型了
- //publicTqueryForObject(Stringsql,ParameterizedRowMapperrm,Object...args)throwsDataAccessException
- Useru=simple.queryForObject(sql,
- ParameterizedBeanPropertyRowMapper.newInstance(
- User.class),name);//這個(gè)行映射器的參數(shù)是可變長的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());
- ///參數(shù)命名方法查詢NamedParameterJdbcTemplate
- //兩種參數(shù)傳遞方法BeanPropertySqlParameterSource(user)、MapSqlParameterSource
- //bean屬性參數(shù)源
- staticUserfindUser(Useruser)
- {
- //Bean屬性參數(shù)源使用方法(參數(shù)別名要與bean類的屬性對應(yīng)，如:money,:id)(通過&號也可以命名別名，不建議使用)
- Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";
- SqlParameterSourceps=newBeanPropertySqlParameterSource(user);
- Objectu=named.queryForObject(sql,ps,newBeanPropertyRowMapper(
- User.class));//這個(gè)方法當(dāng)查詢對象多于一個(gè)或?yàn)閚ull時(shí)會拋異常
- return(User)u;
- }
- //Map參數(shù)源
- 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));//這個(gè)方法當(dāng)查詢對象多于一個(gè)或?yàn)閚ull時(shí)會拋異常
- return(User)u;
- }
- //泛型技術(shù)(JDK1.5以上版本可使用)
- //使用泛型技術(shù)與可變長度的參數(shù)(JDK1.5版本以上)
- staticUserfindUserSimple(Stringname)
- {
- SimpleJdbcTemplatesimple=newSimpleJdbcTemplate(JdbcUtil.getDataSource());
- Stringsql="selectid,name,money,birthdayfromuserwheremoney>:moneyandid<:id";
- //用這個(gè)泛型，返回結(jié)果就不用向下轉(zhuǎn)型了
- //publicTqueryForObject(Stringsql,ParameterizedRowMapperrm,Object...args)throwsDataAccessException
- Useru=simple.queryForObject(sql,
- ParameterizedBeanPropertyRowMapper.newInstance(
- User.class),name);//這個(gè)行映射器的參數(shù)是可變長的Object...
- returnu;
- }
- }
【編輯推薦】
