怎么把数据从oracle11迁到oracle12

怎么把数据从oracle11迁到oracle12,第1张

oracle 111可以直接升级到121的版本,详细可以见mos相关可以直接升级的指导
os:RHEL 55
oracle:11107, 单实例
方式:采用out-of place的升级方式
111的ORACLE_HOME为/u01/app/oracle/product/1117/db_1
121的ORACLE_HOME为/u01/app/oracle/product/1210/db_1
1,rman备份原有数据库;
2,安装oracle 12的软件到/u01/app/oracle/product/1210/db_1;
3,清除回收站,检查无效的对像和无效的组件,确认隐含参数使用情况必须的对像
例12c xdb是必须要组件,
4,收集gater_dictionary_stats和gather_fixed_objects_stats,aud$对像清空,
5,对数据库库进行逻辑检查 ,rman:backup validate check logical database;
6,在111的库实行升级预检查SQL> @/u01/app/oracle/product/1210/db_1/rdbms/admin/preupgrdsql;
该过程会生成一个log文件,对于其中的问题需要解决然后才能升级
7, 使用12C的orapwd生成新的密码文件主,使用原来的spfile生成一个pfile。
8,关闭原来的实例,使用新的ORACLE_HOME启动数据库
[oracle@localhost ~]$ export ORACLE_HOME=/u01/app/oracle/product/1210/db_1
[oracle@localhost ~]$ sqlplus /nolog
SQLPlus: Release 121010 Production on Sat May 10 13:34:57 2014
Copyright (c) 1982, 2013, Oracle All rights reserved
SQL> conn / as sysdba;
Connected to an idle instance
SQL> startup upgrade pfile='/home/oracle/12ora';
ORACLE instance started

9, 并行运行脚本(12c新特性),并行度8,会启动16个并行服务器进程
[oracle@localhost admin]$ /u01/app/oracle/product/1210/db_1/perl/bin/perl catctlpl -n 8 catupgrdsql
Serial Phase #:54 Files: 1 Time: 157s
Serial Phase #:55 Files: 1 Time: 141s
Serial Phase #:56 Files: 1 Time: 48s
Grand Total Time: 2439s

10,以正常的方式启动数据,并且创建spfile
SQL> startup nomount pfile='/home/oracle/12ora';
ORACLE instance started
Total System Global Area 2288205824 bytes
Fixed Size 2290848 bytes
Variable Size 1275071328 bytes
Database Buffers 989855744 bytes
Redo Buffers 20987904 bytes
SQL> create spfile from pfile='/home/oracle/12ora';
File created
SQL> shutdown immediate;
ORA-01507: database not mounted
ORACLE instance shut down
SQL> startup;
ORACLE instance started
Total System Global Area 2288205824 bytes
Fixed Size 2290848 bytes
Variable Size 1275071328 bytes
Database Buffers 989855744 bytes
Redo Buffers 20987904 bytes
Database mounted
Database opened
11,重新收集gather_dictionary_stats和gather_fixed_objects_stats
SQL> exec dbms_statsgather_dictionary_stats;
PL/SQL procedure successfully completed
SQL> exec dbms_statsgather_fixed_objects_stats;
PL/SQL procedure successfully completed
12,重新编译无效对像
SQL> @utlprp 8; (cpu核数的一到两倍)
TIMESTAMP
--------------------------------------------------------------------------------
COMP_TIMESTAMP UTLRP_BGN 2014-05-10 14:40:44

13, 运行utlu121ssql和utluiobjsql检查无效的对像

proe软件可以打开stp文件,打开的具体 *** 作步骤如下:
1、首先我们打开电脑里的proe软件进入软件主界面。
/iknow-piccdnbceboscom/8b82b9014a90f60353a37e083712b31bb051ed6a"target="_blank"title="大图"class="ikqb_img_alink">/iknow-piccdnbceboscom/8b82b9014a90f60353a37e083712b31bb051ed6ax-bce-process=image%2Fresize%2Cm_lfit%2Cw_600%2Ch_800%2Climit_1%2Fquality%2Cq_85%2Fformat%2Cf_auto"esrc=">随着计算机技术的快速发展,以往使用PRP(纸带阅读穿孔机)、U盘与CNC系统进行NC程序输入/输出的技术,由于保存,管理,容量,可靠性等均存在不足之处,正逐渐被淘汰。同时,企业数控设备的数量越来越多,而传统的单机管理模式因技术手段落后、生产效率低、管理与维护费用高昂等弊端已不能适应企业发展的需要,再加上用户使用了多种信息管理系统,如ERP,PDM,MDC,Tracker,CRM,CAD/CAPP/CAM等,各种系统之间还必须考虑信息共享,以避免信息化孤岛。因此,使用集成式DNC技术对数控设备群进行管理势在必行。

盖勒普DNC(Distributed Numerical Control)作为数控设备联网管理系统,它的主要功能是通过1台服务器,对生产现场所有的数控设备进行集中联网管理(目前已能在64位机上实现对4096台设备集中联网管理)。程序编程人员可以在自己的计算机上进行编程,并上传至DNC服务器指定的目录下,而后现场设备 *** 作者即可通过设备CNC控制器发送“下载(LOAD)”指令,从服务器中下载所需的程序,待程序加工完毕后再通过DNC网络回传至服务器中,由程序管理员或工艺人员进行比较或归档。这种方式大大减少了数控程序的准备时间,消除了人员在工艺室与设备端的奔波,并且可完全确保程序的完整性和可靠性,消除了很多人为导致的“失误”。最重要的是,通过盖勒普DNC系统,能够实现CAD/CAM和计算机辅助生产管理系统集成,是机械加工自动化的又一种形式。

传统的DNC系统仅仅能实现程序传输的功能。随着信息化技术的发展,目前的DNC系统已经发展为可以集成部分制造执行系统 (Manufacturing Execution System,简称MES)功能的系统软件。早在上世纪90年代初,盖勒普DNC系统就赋予DNC更广阔的内涵:生产设备及工位智能化联网管理系统,这也是全球范围内最早且使用最成熟的“物联网”技术——车间内“物联网”。它不仅能够使所有的CNC数控加工中心、智能化工业机器人、自动化生产线PLC工作中心及其它所有的工业设备联网在线,同时还能有效管理生产设备、加工程序和工位信息,实现车间生产设备的网络化管理,使企业的管理水平得到了新的提高。

近年来,企业对DNC系统的需求已经远远不满足于原始的基本功能,为了进一步保证程序的完整性和生产质量的安全性,盖勒普DNC系统已经支持BCR条码扫描进行直接下载NC程序功能;另外,为了配合企业精益生产6S管理的目标,盖勒普率先推出了WDNC无线设备联网管理解决方案。在对NC程序的集中管理和通讯传输基础上,盖勒普DNC能够对生产过程中其他有关联性的文档,如:图纸、配刀表、指导说明、检验要求等进行集中管理和通讯传输,并支持直接在客户端中内嵌式浏览和查阅。除此之外,盖勒普DNC的众多用户还会应用在线加工、子程序调用、收发邮件、计划传输、自定义后置等多种(备注:后面已经出现“更多”,不能重复)功能。而盖勒普DNC系统独有的开放式功能库,还将继续实现客户更多的需求和目标。

目前,尤其在国内信息化普及率还不高,相关技术监管指标还不健全的情况下,众多DNC系统参差不穷。有很多国内学院派开发的DNC软件,也有国外较为简单的DNC软件,还有很多设备厂家提供或网上已被解码的免费DNC软件。而之所以均称之为DNC软件并非系统,是由于这些软件在没有经过长期客户应用和技术沉淀下,仍然不够完善和健全,只可作为一个传输通讯的工具。因此,制造企业在进行DNC系统的选型时,一定要格外谨慎,毕竟DNC作为一种工业级的设备联网管理系统,在其几十年的发展历程中,国外成熟的系统都没有几套,国内在短短几年的时间内,能够开发出这样一套完整的DNC系统,几乎是不可能的。

未来,DNC系统必须能够承载更多的信息。同时DNC系统必须能有效的结合先进的数字化数据录入或读出技术,如条码技术、射频技术、触屏技术等,帮助企业实现生产工位的数字化。随着数控技术的发展,具备在以太网上运行的数控系统逐渐得到了广泛的应用,因此今后的DNC数控设备联网系统将与企业内部的局域网成为一个统一的系统,其维护与管理将变得更为快捷方便。

制造企业引入DNC系统的原则:
1企业内的数控机床数量。出于对生产效率和成本的考虑,一般情况下,在企业拥有4-6台NC机床或者更多时,即应考虑DNC系统;
2控制系统要处理的数据量。在数据量很大且程序的处理速度要求很快时,应考虑DNC系统;
3NC程序的管理。NC程序管理的问题、难度越大,就越应当考虑采用DNC系统;
4NC程序的长度。在CNC的程序存储器不能满足程序的要求时,应考虑DNC系统;
5在加工中需要频繁更换程序。加工的批量越小,程序越小,在正确的机床上,正确的时间内,使用正确的程序加工就越困难,但如果采用DNC系统就能比较容易地解决这个问题。
盖勒普公司简介
盖勒普是一家由美国著名的Predator Software软件技术公司和Gallop国际科技联合创立的外资独资高科技服务公司。国外总部1995年创建于美国工业之城芝加哥市,并在美国的工商业城洛杉矶、汽车城底特律、硅谷圣何塞和西北高科技城西雅图等市设有业务代联络处。在中国的业务起始于提供世界先进的机电产品设计和制造一体化的工程技术咨询及相关软、硬件培训和系统集成服务。中国公司总部位于中国最大的工业科技城——上海,重点致力于中国制造业信息化事业的市场推广、系统解决方案实施和技术服务工作。
盖勒普公司不仅作为美国著名的Predator Software软件技术公司在中国业务的运营中心,同时也是大中国区提供Predator SFC-MES系统产品解决方案洲际级技术中心,该中心是其在全球数十家技术地区服务中心中负责中国及东南亚地区的技术服务点。近10多年来,盖勒普公司凭借美国Predator在全球航太、机电及汽车等制造行业20多年的系统产品研发、市场推广和提供解决方案中所获得的丰富技术、市场经验及行业口碑,已经与众多国内外著名厂商达成了战略联盟和项目合作关系,向国内制造业各类型客户提供了多种多样帮助他们提高生产现场控制和信息化生产管理效益的全面有效解决方案。

1222=nerv SNI R&D network
1239=nmsd NMSD
1243=Sub-7木马
1245=Vodoo
1248=hermes
1269=Mavericks Matrix
1492=FTP99CMP (BackOrifficeFTP)
1509=Streaming Server
1524=ingreslock后门
1313=bmc_patroldb
1314=pdps
1321=pip PIP
1345=vpjp VPJP
1346=alta-ana-lm
1347=bbn-mmc
1348=bbn-mmx
1349=sbook Registration Network Protocol
1350=editbench
1352=lotusnote
1353=relief
1354=rightbrain
1355=intuitive-edge
1356=cuillamartin
1357=pegboard
1358=connlcli
1359=ftsrv
1360=mimer
1361=linx
1362=timeflies
1363=ndm-requester
1364=ndm-server
1365=adapt-sna
1366=netware-csp
1367=dcs
1368=screencast
1369=gv-us
1370=us-gv
1371=fc-cli
1372=fc-ser
1373=chromagrafx
1374=molly EPI Software Systems
1375=bytex
1376=ibm-pps
1377=cichlid
1378=elan
1379=dbreporter Integrity Solutions
1380=telesis-licman
1381=apple-licman
1382=udt_os
1383=gwha
1384=os-licman
1385=atex_elmd
1386=checksum
1387=cadsi-lm
1388=objective-dbc
1389=iclpv-dm
1390=iclpv-sc
1391=iclpv-sas
1392=iclpv-pm
1393=iclpv-nls
1394=iclpv-nlc
1395=iclpv-wsm
1396=dvl-activemail
1399=cadkey-licman
1400=cadkey-tablet
1402=prm-sm-np
1403=prm-nm-np
1404=igi-lm
1405=ibm-res
1406=netlabs-lm
1407=dbsa-lm
1408=sophia-lm
1409=here-lm
1410=hiq
1411=af AudioFile
1412=innosys
1413=innosys-acl
1414=ibm-mqseries
1415=dbstar
1416=novell-lu62
1417=timbuktu-srv1
1418=timbuktu-srv2
1419=timbuktu-srv3
1420=timbuktu-srv4
1421=gandalf-lm
1422=autodesk-lm
1423=essbase
1424=hybrid
1425=zion-lm
1426=sais
1427=mloadd
1428=inFORMatik-lm
1429=nms Hypercom NMS
1430=tpdu Hypercom TPDU
1431=rgtp
1432=blueberry-lm
1433=ms-sql-s
1434=ms-sql-m
1435=ibm-cics
1436=saism
1437=tabula
1438=eicon-server
1439=eicon-x25
1440=eicon-slp
1441=cadis-1
1442=cadis-2
1443=ies-lm
1444=marcam-lm
1445=proxima-lm
1446=ora-lm
1447=apri-lm
1448=oc-lm
1449=peport
1450=dwf
1451=infoman
1452=gtegsc-lm
1453=genie-lm
1454=interhdl_elmd
1455=esl-lm
1456=dca
1457=valisys-lm
1458=nrcabq-lm
1459=proshare1
1460=proshare2
1461=ibm_wrless_lan
1462=world-lm
1463=nucleus
1464=msl_lmd
1465=pipes
1466=oceansoft-lm
1467=csdmbase
1468=csdm
1469=aal-lm
1470=uaiact
1471=csdmbase
1472=csdm
1473=openmath
1474=telefinder
1475=taligent-lm
1476=clvm-cfg
1477=ms-sna-server
1478=ms-sna-base
1479=dberegister
1480=pacerforum
1481=airs
1482=miteksys-lm
1483=afs
1484=confluent
1485=lansource
1486=nms_topo_serv
1487=localinfosrvr
1488=docstor
1489=dmdocbroker
1490=insitu-conf
1491=anynetgateway
1492=stone-design-1
1493=netmap_lm
1494=ica
1495=cvc
1496=liberty-lm
1497=rfx-lm
1498=sybase-sqlany
1499=fhc
1500=vlsi-lm
1501=saiscm
1502=shivadiscovery
1503=imtc-mcs
1504=evb-elm
1505=funkproxy
1506=utcd
1507=symplex
1508=diagmond
1509=robcad-lm
1510=mvx-lm
1511=3l-l1
1512=wins
1513=fujitsu-dtc
1514=fujitsu-dtcns
1515=ifor-protocol
1516=vpad
1517=vpac
1518=vpvd
1519=vpvc
1520=atm-zip-office
1521=ncube-lm
1522=ricardo-lm
1523=cichild-lm
1525=orasrv
1525=prospero-np
1526=pdap-np
1527=tlisrv
1528=mciautoreg
1529=coauthor
1530=rap-service
1531=rap-listen
1532=miroconnect
1533=virtual-places
1534=micromuse-lm
1535=ampr-info
1536=ampr-inter
1537=sdsc-lm
1538=3ds-lm
1539=intellistor-lm
1540=rds
1541=rds2
1542=gridgen-elmd
1543=simba-cs
1544=aspeclmd
1545=vistium-share
1546=abbaccuray
1547=laplink
1548=axon-lm
1549=shivahose
1550=3m-image-lm
1551=hecmtl-db
1552=pciarray
1553=sna-cs
1554=caci-lm
1555=livelan
1556=ashwin
1557=arbortext-lm
1558=xingmpeg
1559=web2host
1560=asci-val
1561=facilityview
1562=pconnectmgr
1563=cadabra-lm
1564=pay-per-view
1565=winddlb
1566=corelvideo
1567=jlicelmd
1568=tsspmap
1569=ets
1570=orbixd
1571=rdb-dbs-disp
1572=Chipcom License Manager
1573=itscomm-ns
1574=mvel-lm
1575=oraclenames
1576=moldflow-lm
1577=hypercube-lm
1578=Jacobus License Manager
1579=ioc-sea-lm
1580=tn-tl-r1 tn-tl-r1
1581=mil-2045-47001
1582=msims
1583=simbaexpress
1584=tn-tl-fd2
1585=intv
1586=ibm-abtact
1587=pra_elmd
1588=triquest-lm
1589=vqp
1590=gemini-lm
1591=ncpm-pm
1592=commonspace
1593=mainsoft-lm
1594=sixtrak
1595=radio
1596=radio-sm
1597=orbplus-iiop
1598=picknfs
1599=simbaservices
1600=Shiv
1601=aas
1602=inspect
1603=picodbc
1604=icabrowser icabrowser
1605=slp Salutation Manager
1606=Salutation Manager
1607=stt
1608=Smart Corp License Manager
1609=isysg-lm
1610=taurus-wh
1611=ill Inter Library Loan
1612=NetBill Transaction Server
1613=NetBill Key Repository
1614=NetBill Credential Server
1615=NetBill Authorization Server
1616=NetBill Product Server
1617=Nimrod Inter-Agent Communication
1618=skytelnet
1619=xs-openstorage
1620=faxportwinport
1621=softdataphone
1622=ontime
1623=jaleosnd
1624=udp-sr-port
1625=svs-omagent
1636=cncp
1637=cnap
1638=cnip
1639=cert
1640=cert-responder
1641=invision
1642=isis-am
1643=isis-ambc
1645=datametrics
1646=sa-msg-port
1647=rsap rsap
1648=concurrent-lm
1649=inspect
1650=nkd
1651=shiva_confsrvr
1652=xnmp
1653=alphatech-lm
1654=stargatealerts
1655=dec-mbadmin
1656=dec-mbadmin-h
1657=fujitsu-mmpdc
1658=sixnetudr
1659=sg-lm
1660=skip-mc-gikreq
1661=netview-aix-1
1662=netview-aix-2
1663=netview-aix-3
1664=netview-aix-4
1665=netview-aix-5
1666=netview-aix-6
1667=netview-aix-7
1668=netview-aix-8
1669=netview-aix-9
1670=netview-aix-10
1671=netview-aix-11
1672=netview-aix-12
1673=Intel Proshare Multicast
1674=Intel Proshare Multicast
1675=pdp Pacific Data Products
1676=netcomm1
1677=groupwise
1678=prolink
1679=darcorp-lm
1681=sd-elmd
1682=lanyon-lantern
1683=ncpm-hip
1684=snaresecure
1685=n2nremote
1686=cvmon cvmon
1687=nsjtp-ctrl
1688=nsjtp-data
1689=firefox
1690=ng-umds
1691=empire-empuma
1692=sstsys-lm
1693=rrirtr
1694=rrimwm
1695=rrilwm
1696=rrifmm
1697=rrisat
1698=rsvp-encap-1
1699=rsvp-encap-2
1700=mps-raft
1701=l2f,l2tp
1702=deskshare
1703=hb-engine
1704=bcs-broker
1705=slingshot
1706=jetFORM
1707=vdmplay
1708=gat-lmd
1709=centra
1710=impera
1711=pptconference
1712=registrar resource monitoring service
1713=conferencetalk
1714=sesi-lm
1715=houdini-lm
1716=xmsg
1717=fj-hdnet
1718=h323gatedisc
1719=h323gatestat
1720=h323hostcall
1721=caicci
1722=HKS License Manager
1723=pptp
1724=csbphonemaster
1725=iden-ralp
1726=iberiagames
1727=winddx
1728=telindus
1729=CityNL License Management
1730=roketz
1731=msiccp
1732=proxim
1733=sSIIPAT Protocol for Alarm Transmission
1734=Camber
1735=privatechat
1736=street-stream
1737=ultimad
1738=gamegen1
1739=webaccess
1740=encore
1741=cisco-net-mgmt
1742=3Com-nsd
1743=Cinema Graphics License Manager
1744=ncpm-ft
1745=remote-winsock
1746=ftrapid-1
1747=ftrapid-2
1748=oracle-em1
1749=aspen-services
1750=Simple Socket Library's PortMaster
1751=swiftnet
1752=Leap of Faith Research License Manager
1753=Translogic License Manager
1754=oracle-em2
1755=ms-streaming
1756=capfast-lmd
1757=cnhrp
1758=tftp-mcast
1759=SPSS License Manager
1760= >连接池用法JDBC
Java Servlet作为首选的服务器端数据处理技术,正在迅速取代CGI脚本。Servlet超越CGI的优势之一在于,不仅多个请求可以共享公用资源,而且还可以在不同用户请求之间保留持续数据。本文介绍一种充分发挥该特色的实用技术,即数据库连接池
一、实现连接池的意义
动态Web站点往往用数据库存储的信息生成Web页面,每一个页面请求导致一次数据库访问。连接数据库不仅要开销一定的通讯和内存资源,还必须完成用户验证、安全上下文配置这类任务,因而往往成为最为耗时的 *** 作。当然,实际的连接时间开销千变万化,但1到2秒延迟并非不常见。如果某个基于数据库的Web应用只需建立一次初始连接,不同页面请求能够共享同一连接,就能获得显著的性能改善。
Servlet是一个Java类。Servlet引擎(它可能是Web服务软件的一部分,也可能是一个独立的附加模块)在系统启动或Servlet第一次被请求时将该类装入Java虚拟机并创建它的一个实例。不同用户请求由同一Servlet实例的多个独立线程处理。那些要求在不同请求之间持续有效的数据既可以用Servlet的实例变量来保存,也可以保存在独立的辅助对象中。
用JDBC访问数据库首先要创建与数据库之间的连接,获得一个连接对象(Connection),由连接对象提供执行SQL语句的方法。本文介绍的数据库连接池包括一个管理类DBConnectionManager,负责提供与多个连接池对象(DBConnectionPool类)之间的接口。每一个连接池对象管理一组JDBC连接对象,每一个连接对象可以被任意数量的Servlet共享。
类DBConnectionPool提供以下功能:
1) 从连接池获取(或创建)可用连接。
2) 把连接返回给连接池。
3) 在系统关闭时释放所有资源,关闭所有连接。
此外, DBConnectionPool类还能够处理无效连接(原来登记为可用的连接,由于某种原因不再可用,如超时,通讯问题),并能够限制连接池中的连接总数不超过某个预定值。
管理类DBConnectionManager用于管理多个连接池对象,它提供以下功能:
1) 装载和注册JDBC驱动程序。
2) 根据在属性文件中定义的属性创建连接池对象。
3) 实现连接池名字与其实例之间的映射。
4) 跟踪客户程序对连接池的引用,保证在最后一个客户程序结束时安全地关闭所有连接池。
本文余下部分将详细说明这两个类,最后给出一个示例演示Servlet使用连接池的一般过程。
二、具体实现
DBConnectionManagerjava程序清单如下:
001 import javaio;
002 import javasql;
003 import javautil;
004 import javautilDate;
005
006 /
007 管理类DBConnectionManager支持对一个或多个由属性文件定义的数据库连接
008 池的访问客户程序可以调用getInstance()方法访问本类的唯一实例
009 /
010 public class DBConnectionManager {
011 static private DBConnectionManager instance; // 唯一实例
012 static private int clients;
013
014 private Vector drivers = new Vector();
015 private PrintWriter log;
016 private Hashtable pools = new Hashtable();
017
018 /
019 返回唯一实例如果是第一次调用此方法,则创建实例
020
021 @return DBConnectionManager 唯一实例
022 /
023 static synchronized public DBConnectionManager getInstance() {
024 if (instance == null) {
025 instance = new DBConnectionManager();
026 }
027 clients++;
028 return instance;
029 }
030
031 /
032 建构函数私有以防止其它对象创建本类实例
033 /
034 private DBConnectionManager() {
035 init();
036 }
037
038 /
039 将连接对象返回给由名字指定的连接池
040
041 @param name 在属性文件中定义的连接池名字
042 @param con 连接对象
043 /
044 public void freeConnection(String name, Connection con) {
045 DBConnectionPool pool = (DBConnectionPool) poolsget(name);
046 if (pool != null) {
047 poolfreeConnection(con);
048 }
049 }
050
051 /
052 获得一个可用的(空闲的)连接如果没有可用连接,且已有连接数小于最大连接数
053 限制,则创建并返回新连接
054
055 @param name 在属性文件中定义的连接池名字
056 @return Connection 可用连接或null
057 /
058 public Connection getConnection(String name) {
059 DBConnectionPool pool = (DBConnectionPool) poolsget(name);
060 if (pool != null) {
061 return poolgetConnection();
062 }
063 return null;
064 }
065
066 /
067 获得一个可用连接若没有可用连接,且已有连接数小于最大连接数限制,
068 则创建并返回新连接否则,在指定的时间内等待其它线程释放连接
069
070 @param name 连接池名字
071 @param time 以毫秒计的等待时间
072 @return Connection 可用连接或null
073 /
074 public Connection getConnection(String name, long time) {
075 DBConnectionPool pool = (DBConnectionPool) poolsget(name);
076 if (pool != null) {
077 return poolgetConnection(time);
078 }
079 return null;
080 }
081
082 /
083 关闭所有连接,撤销驱动程序的注册
084 /
085 public synchronized void release() {
086 // 等待直到最后一个客户程序调用
087 if (--clients != 0) {
088 return;
089 }
090
091 Enumeration allPools = poolselements();
092 while (allPoolshasMoreElements()) {
093 DBConnectionPool pool = (DBConnectionPool) allPoolsnextElement();
094 poolrelease();
095 }
096 Enumeration allDrivers = driverselements();
097 while (allDrivershasMoreElements()) {
098 Driver driver = (Driver) allDriversnextElement();
099 try {
100 DriverManagerderegisterDriver(driver);
101 log("撤销JDBC驱动程序 " + drivergetClass()getName()+"的注册");
102 }
103 catch (SQLException e) {
104 log(e, "无法撤销下列JDBC驱动程序的注册: " + drivergetClass()getName());
105 }
106 }
107 }
108
109 /
110 根据指定属性创建连接池实例
111
112 @param props 连接池属性
113 /
114 private void createPools(Properties props) {
115 Enumeration propNames = propspropertyNames();
116 while (propNameshasMoreElements()) {
117 String name = (String) propNamesnextElement();
118 if (nameendsWith("url")) {
119 String poolName = namesubstring(0, namelastIndexOf(""));
120 String url = propsgetProperty(poolName + "url");
121 if (url == null) {
122 log("没有为连接池" + poolName + "指定URL");
123 continue;
124 }
125 String user = propsgetProperty(poolName + "user");
126 String password = propsgetProperty(poolName + "password");
127 String maxconn = propsgetProperty(poolName + "maxconn", "0");
128 int max;
129 try {
130 max = IntegervalueOf(maxconn)intValue();
131 }
132 catch (NumberFormatException e) {
133 log("错误的最大连接数限制: " + maxconn + " 连接池: " + poolName);
134 max = 0;
135 }
136 DBConnectionPool pool =
137 new DBConnectionPool(poolName, url, user, password, max);
138 poolsput(poolName, pool);
139 log("成功创建连接池" + poolName);
140 }
141 }
142 }
143
144 /
145 读取属性完成初始化
146 /
147 private void init() {
148 InputStream is = getClass()getResourceAsStream("/dbproperties");
149 Properties dbProps = new Properties();
150 try {
151 dbPropsload(is);
152 }
153 catch (Exception e) {
154 Systemerrprintln("不能读取属性文件 " +
155 "请确保dbproperties在CLASSPATH指定的路径中");
156 return;
157 }
158 String logFile = dbPropsgetProperty("logfile", "DBConnectionManagerlog");
159 try {
160 log = new PrintWriter(new FileWriter(logFile, true), true);
161 }
162 catch (IOException e) {
163 Systemerrprintln("无法打开日志文件: " + logFile);
164 log = new PrintWriter(Systemerr);
165 }
166 loadDrivers(dbProps);
167 createPools(dbProps);
168 }
169
170 /
171 装载和注册所有JDBC驱动程序
172
173 @param props 属性
174 /
175 private void loadDrivers(Properties props) {
176 String driverClasses = propsgetProperty("drivers");
177 StringTokenizer st = new StringTokenizer(driverClasses);
178 while (sthasMoreElements()) {
179 String driverClassName = stnextToken()trim();
180 try {
181 Driver driver = (Driver)
182 ClassforName(driverClassName)newInstance();
183 DriverManagerregisterDriver(driver);
184 driversaddElement(driver);
185 log("成功注册JDBC驱动程序" + driverClassName);
186 }
187 catch (Exception e) {
188 log("无法注册JDBC驱动程序: " +
189 driverClassName + ", 错误: " + e);
190 }
191 }
192 }
193
194 /
195 将文本信息写入日志文件
196 /
197 private void log(String msg) {
198 logprintln(new Date() + ": " + msg);
199 }
200
201 /
202 将文本信息与异常写入日志文件
203 /
204 private void log(Throwable e, String msg) {
205 logprintln(new Date() + ": " + msg);
206 eprintStackTrace(log);
207 }
208
209 /
210 此内部类定义了一个连接池它能够根据要求创建新连接,直到预定的最
211 大连接数为止在返回连接给客户程序之前,它能够验证连接的有效性
212 /
213 class DBConnectionPool {
214 private int checkedOut;
215 private Vector freeConnections = new Vector();
216 private int maxConn;
217 private String name;
218 private String password;
219 private String URL;
220 private String user;
221
222 /
223 创建新的连接池
224
225 @param name 连接池名字
226 @param URL 数据库的JDBC URL
227 @param user 数据库帐号,或 null
228 @param password 密码,或 null
229 @param maxConn 此连接池允许建立的最大连接数
230 /
231 public DBConnectionPool(String name, String URL, String user, String password,
232 int maxConn) {
233 thisname = name;
234 thisURL = URL;
235 thisuser = user;
236 thispassword = password;
237 thismaxConn = maxConn;
238 }
239
240 /
241 将不再使用的连接返回给连接池
242
243 @param con 客户程序释放的连接
244 /
245 public synchronized void freeConnection(Connection con) {
246 // 将指定连接加入到向量末尾
247 freeConnectionsaddElement(con);
248 checkedOut--;
249 notifyAll();
250 }
251
252 /
253 从连接池获得一个可用连接如没有空闲的连接且当前连接数小于最大连接
254 数限制,则创建新连接如原来登记为可用的连接不再有效,则从向量删除之,
255 然后递归调用自己以尝试新的可用连接
256 /
257 public synchronized Connection getConnection() {
258 Connection con = null;
259 if (freeConnectionssize() > 0) {
260 // 获取向量中第一个可用连接
261 con = (Connection) freeConnectionsfirstElement();
262 freeConnectionsremoveElementAt(0);
263 try {
264 if (conisClosed()) {
265 log("从连接池" + name+"删除一个无效连接");
266 // 递归调用自己,尝试再次获取可用连接
267 con = getConnection();
268 }
269 }
270 catch (SQLException e) {
271 log("从连接池" + name+"删除一个无效连接");
272 // 递归调用自己,尝试再次获取可用连接
273 con = getConnection();
274 }
275 }
276 else if (maxConn == 0 || checkedOut < maxConn) {
277 con = newConnection();
278 }
279 if (con != null) {
280 checkedOut++;
281 }
282 return con;
283 }
284
285 /
286 从连接池获取可用连接可以指定客户程序能够等待的最长时间
287 参见前一个getConnection()方法
288
289 @param timeout 以毫秒计的等待时间限制
290 /
291 public synchronized Connection getConnection(long timeout) {
292 long startTime = new Date()getTime();
293 Connection con;
294 while ((con = getConnection()) == null) {
295 try {
296 wait(timeout);
297 }
298 catch (InterruptedException e) {}
299 if ((new Date()getTime() - startTime) >= timeout) {
300 // wait()返回的原因是超时
301 return null;
302 }
303 }
304 return con;
305 }
306
307 /
308 关闭所有连接
309 /
310 public synchronized void release() {
311 Enumeration allConnections = freeConnectionselements();
312 while (allConnectionshasMoreElements()) {
313 Connection con = (Connection) allConnectionsnextElement();
314 try {
315 conclose();
316 log("关闭连接池" + name+"中的一个连接");
317 }
318 catch (SQLException e) {
319 log(e, "无法关闭连接池" + name+"中的连接");
320 }
321 }
322 freeConnectionsremoveAllElements();
323 }
324
325 /
326 创建新的连接
327 /
328 private Connection newConnection() {
329 Connection con = null;
330 try {
331 if (user == null) {
332 con = DriverManagergetConnection(URL);
333 }
334 else {
335 con = DriverManagergetConnection(URL, user, password);
336 }
337 log("连接池" + name+"创建一个新的连接");
338 }
339 catch (SQLException e) {
340 log(e, "无法创建下列URL的连接: " + URL);
341 return null;
342 }
343 return con;
344 }
345 }
346 }
三、类DBConnectionPool说明
该类在209至345行实现,它表示指向某个数据库的连接池。数据库由JDBC URL标识。一个JDBC URL由三部分组成:协议标识(总是jdbc),驱动程序标识(如 odbc、idb、oracle等),数据库标识(其格式依赖于驱动程序)。例如,jdbcdbc:demo,即是一个指向demo数据库的JDBC URL,而且访问该数据库要使用JDBC-ODBC驱动程序。每个连接池都有一个供客户程序使用的名字以及可选的用户帐号、密码、最大连接数限制。如果Web应用程序所支持的某些数据库 *** 作可以被所有用户执行,而其它一些 *** 作应由特别许可的用户执行,则可以为两类 *** 作分别定义连接池,两个连接池使用相同的JDBC URL,但使用不同的帐号和密码。
类DBConnectionPool的建构函数需要上述所有数据作为其参数。如222至238行所示,这些数据被保存为它的实例变量:
如252至283行、285至305行所示, 客户程序可以使用DBConnectionPool类提供的两个方法获取可用连接。两者的共同之处在于:如连接池中存在可用连接,则直接返回,否则创建新的连接并返回。如果没有可用连接且已有连接总数等于最大限制数,第一个方法将直接返回null,而第二个方法将等待直到有可用连接为止。
所有的可用连接对象均登记在名为freeConnections的向量(Vector)中。如果向量中有多于一个的连接,getConnection()总是选取第一个。同时,由于新的可用连接总是从尾部加入向量,从而使得数据库连接由于长时间闲置而被关闭的风险减低到最小程度。
第一个getConnection()在返回可用连接给客户程序之前,调用了isClosed()方法验证连接仍旧有效。如果该连接被关闭或触发异常,getConnection()递归地调用自己以尝试获取另外的可用连接。如果在向量freeConnections中不存在任何可用连接,getConnection()方法检查是否已经指定最大连接数限制。如已经指定,则检查当前连接数是否已经到达极限。此处maxConn为0表示没有限制。如果没有指定最大连接数限制或当前连接数小于该值,该方法尝试创建新的连接。如创建成功,则增加已使用连接的计数并返回,否则返回空值。
如325至345行所示,创建新连接由newConnection()方法实现。创建过程与是否已经指定数据库帐号、密码有关。
JDBC的DriverManager类提供多个getConnection()方法,这些方法要用到JDBC URL与其它一些参数,如用户帐号和密码等。DriverManager将使用指定的JDBC URL确定适合于目标数据库的驱动程序及建立连接。
在285至305行实现的第二个getConnection()方法需要一个以毫秒为单位的时间参数,该参数表示客户程序能够等待的最长时间。建立连接的具体 *** 作仍旧由第一个getConnection()方法实现。
该方法执行时先将startTime初始化为当前时间。在while循环中尝试获得一个连接。如果失败,则以给定的时间值为参数调用wait()。wait()的返回可能是由于其它线程调用notify()或notifyAll(),也可能是由于预定时间已到。为找出wait()返回的真正原因,程序用当前时间减开始时间(startTime),如差值大于预定时间则返回空值,否则再次调用getConnection()。
把空闲的连接登记到连接池由240至250行的freeConnection()方法实现,它的参数为返回给连接池的连接对象。该对象被加入到freeConnections向量的末尾,然后减少已使用连接计数。调用notifyAll()是为了通知其它正在等待可用连接的线程。
许多Servlet引擎为实现安全关闭提供多种方法。数据库连接池需要知道该事件以保证所有连接能够正常关闭。DBConnectionManager类负协调整个关闭过程,但关闭连接池中所有连接的任务则由DBConnectionPool类负责。在307至323行实现的release()方法供DBConnectionManager调用。该方法遍历freeConnections向量并关闭所有连接,然后从向量中删除这些连接。
四、类DBConnectionManager 说明
该类只能创建一个实例,其它对象能够调用其静态方法(也称为类方法)获得该唯一实例的引用。如031至036行所示,DBConnectionManager类的建构函数是私有的,这是为了避免其它对象创建该类的实例。
DBConnectionManager类的客户程序可以调用getInstance()方法获得对该类唯一实例的引用。如018至029行所示,类的唯一实例在getInstance()方法第一次被调用期间创建,此后其引用就一直保存在静态变量instance中。每次调用getInstance()都增加一个DBConnectionManager的客户程序计数。即,该计数代表引用DBConnectionManager唯一实例的客户程序总数,它将被用于控制连接池的关闭 *** 作。
该类实例的初始化工作由146至168行之间的私有方法init()完成。其中 getResourceAsStream()方法用于定位并打开外部文件。外部文件的定位方法依赖于类装载器的实现。标准的本地类装载器查找 *** 作总是开始于类文件所在路径,也能够搜索CLASSPATH中声明的路径。dbproperties是一个属性文件,它包含定义连接池的键-值对。可供定义的公用属性如下:
drivers 以空格分隔的JDBC驱动程序类列表
logfile 日志文件的绝对路径
其它的属性和特定连接池相关,其属性名字前应加上连接池名字:
<poolname>url 数据库的 JDBC URL
<poolname>maxconn 允许建立的最大连接数,0表示没有限制
<poolname>user 用于该连接池的数据库帐号
<poolname>password 相应的密码
其中url属性是必需的,而其它属性则是可选的。数据库帐号和密码必须合法。用于Windows平台的dbproperties文件示例如下:
drivers=sunjdbcodbcJdbcOdbcDriver jdbcidbDriver
logfile=D:\user\src\java\DBConnectionManager\logtxt
idburl=jdbc:idb:c:\local\javawebserver11\db\dbprp
idbmaxconn=2
accessurl=jdbcdbc:demo
accessuser=demo
accesspassword=demopw
注意在Windows路径中的反斜杠必须输入2个,这是由于属性文件中的反斜杠同时也是一个转义字符。
init()方法在创建属性对象并读取dbproperties文件之后,就开始检查logfile属性。如果属性文件中没有指定日志文件,则默认为当前目录下的DBConnectionManagerlog文件。如日志文件无法使用,则向Systemerr输出日志记录。
装载和注册所有在drivers属性中指定的JDBC驱动程序由170至192行之间的loadDrivers()方法实现。该方法先用StringTokenizer将drivers属性值分割为对应于驱动程序名称的字符串,然后依次装载这些类并创建其实例,最后在 DriverManager中注册该实例并把它加入到一个私有的向量drivers。向量drivers将用于关闭服务时从DriverManager取消所有JDBC 驱动程序的注册。
init()方法的最后一个任务是调用私有方法createPools()创建连接池对象。如109至142行所示,createPools()方法先创建所有属性名字的枚举对象(即Enumeration对象,该对象可以想象为一个元素系列,逐次调用其nextElement()方法将顺序返回各元素),然后在其中搜索名字以“url”结尾的属性。对于每一个符合条件的属性,先提取其连接池名字部分,进而读取所有属于该连接池的属性,最后创建连接池对象并把它保存在实例变量pools中。散列表(Hashtable类 )pools实现连接池名字到连接池对象之间的映射,此处以连接池名字为键,连接池对象为值。
为便于客户程序从指定连接池获得可用连接或将连接返回给连接池,类DBConnectionManager提供了方法getConnection()和freeConnection()。所有这些方法都要求在参数中指定连接池名字,具体的连接获取或返回 *** 作则调用对应的连接池对象完成。它们的实现分别在051至064行、066至080行、038至049行。
如082至107行所示,为实现连接池的安全关闭,DBConnectionManager提供了方法release()。在上面我们已经提到,所有DBConnectionManager的客户程序都应该调用静态方法getInstance()以获得该管理器的引用,此调用将增加客户程序计数。客户程序在关闭时调用release()可以递减该计数。当最后一个客户程序调用release(),递减后的引用计数为0,就可以调用各个连接池的release()方法关闭所有连接了。管理类release()方法最后的任务是撤销所有JDBC驱动程序的注册。
五、Servlet使用连接池示例
Servlet API所定义的Servlet生命周期类如:
1) 创建并初始化Servlet(init()方法)。
2) 响应客户程序的服务请求(service()方法)。
3) Servlet终止运行,释放所有资源(destroy()方法)。
本例演示连接池应用,上述关键步骤中的相关 *** 作为:
1) 在init(),用实例变量connMgr 保存调用DBConnectionManagergetInstance()所返回的引用。
2) 在service(),调用getConnection(),执行数据库 *** 作,用freeConnection()将连接返回给连接池。
3) 在destroy(),调用release()关闭所有连接,释放所有资源。
示例程序清单如下:
import javaio;
import javasql;
import javaxservlet;
import javaxservlet>

欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zz/13467708.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-08-13
下一篇 2023-08-13

发表评论

登录后才能评论

评论列表(0条)

保存