龙在沙滩被虾戏,虎落平阳被犬欺.
虎伏深山听风啸,龙卧浅滩等海潮.
海到尽头天做岸,山登绝顶我为峰.
如日东山能在起,大鹏展翅恨天低。
谁无虎落平阳日,待我风山再起时.
有朝一日龙得水,必令长江水倒流.
有朝一日凤囬巢,必让长城永不倒.
有朝一日虎归山,必要血染半边天.
有朝一日狮入林,我要气吼山河震.
有朝一日游地府,我让地府底朝天.
有朝一日游天边,众神跪在我身边.
有朝一日凤翔天,我要天下尽我鸣.
有朝一日我出头,我要天下唯我尊.
天下英雄出我辈,一入江湖岁月摧.
宏图霸业谈笑中,不胜人生一场醉.
Monthly Archives: 二月 2011
sql server 2005镜像配置
1、服务器ip地址和数据库版本
主机:192.168.1.1
备机:192.168.1.110
数据库:sql server 2005 sp4
2、主备实例互通
1)创建证书
--主机执行 USE MASTER GO CREATE MASTER KEY ENCRYPTION BY PASSWORD = 'xifenfei'; GO USE MASTER GO CREATE CERTIFICATE HOST_A_cert WITH SUBJECT = 'A certificate for database mirroring', START_DATE = '11/25/2009', EXPIRY_DATE = '12/31/2199'; GO --备机执行 USE MASTER GO CREATE MASTER KEY ENCRYPTION BY PASSWORD = 'xifenfei'; GO USE MASTER GO CREATE CERTIFICATE HOST_B_cert WITH SUBJECT = 'A certificate for database mirroring', START_DATE = '11/25/2009', EXPIRY_DATE = '12/31/2199'; GO
2)创建连接的端点
--主机执行 create endpoint endpoint_mirroring state=started as tcp (listener_port=5022,listener_ip=all) for database_mirroring (authentication=certificate HOST_A_cert,encryption=supported,role=all); --备机执行 create endpoint endpoint_mirroring state=started as tcp (listener_port=5022,listener_ip=all) for database_mirroring (authentication=certificate HOST_B_cert,encryption=supported,role=all);
3)备份证书以备建立互联
--主机执行 backup certificate HOST_A_cert to file='E:\database\key\HOST_A_cert.cer'; --备机执行 backup certificate HOST_B_cert to file='C:\database\mssql\key\HOST_B_cert.cer';
4)互换备份证书
拷贝证书文件到对象文件夹中
5)添加登录名、用户
--主机执行 create login HOST_B_login with password='20091125'; create user HOST_B_user for login HOST_B_login; create certificate HOST_B_cert authorization HOST_B_user from file='C:\database\mssql\key\HOST_B_cert.cer'; grant connect on endpoint::endpoint_mirroring to [HOST_B_login]; --备机执行 create login HOST_A_login with password='20091125'; create user HOST_A_user for login HOST_A_login; create certificate HOST_A_cert authorization HOST_A_user from file='E:\database\key\HOST_A_cert.cer'; grant connect on endpoint::endpoint_mirroring to [HOST_A_login];
3、建立镜像关系
1)备份还原数据库
/*尝试从刚刚使用的全备文件进行还原,在还原数据的时候需要使用”WITH NO RECOVERY“选项。*/ --主机执行 backup database test to disk='D:\sqlbackup\test091124full.bak' backup log test to disk='D:\sqlbackup\test091124log.bak' --备机执行 restore database acmr_10jqka from disk='D:\sqlbackup\test091124full.bak' with replace,norecovery restore log acmr_10jqka from disk='D:\dbbackup\118_sql\acmr_10jqka091125log.bak' with norecovery
2)建立镜像
/*注意:先备机,后主机*/ --备机执行 alter database acmr_10jqka set partner='TCP://192.168.1.1:5022'; --主机执行 alter database test set partner='TCP://192.168.1.110:5022';
3)事务安全性设置
/*默认情况下,事务安全级别的设置为FULL,即“同步运行模式”,而且,SQL SERVER 2005标准版只支持同步模式。*/ /*如果关闭事务安全级别FULL模式,则可以切换到异步运行模式,该模式可使性能达到最佳。*/ --主机执行 use master go alter database test set partner safety full; --事务安全,同步模式 alter database test set partner safety off; --事务不安全,异步模式
4)切换
--主机执行下面命令后,即切换为备机角色 use master go alter database test set partner failover; /*同理,也可以在备机(主体数据库)上执行上面命令,之后切换为备机(备数据库)*/
show hidden parameter
1、创建查看隐藏参数视图(show_hidden_v$parameter)
--conn "/ as sysdba" create or replace view show_hidden_v$parameter (INST_ID, NUM , NAME , TYPE , VALUE , DISPLAY_VALUE, ISDEFAULT , ISSES_MODIFIABLE , ISSYS_MODIFIABLE , ISINSTANCE_MODIFIABLE, ISMODIFIED , ISADJUSTED , ISDEPRECATED, DESCRIPTION, UPDATE_COMMENT, HASH) as select x.inst_id, x.indx + 1, ksppinm, ksppity, ksppstvl, ksppstdvl, ksppstdf, decode(bitand(ksppiflg / 256, 1), 1, 'TRUE', 'FALSE'), decode(bitand(ksppiflg / 65536, 3), 1, 'IMMEDIATE', 2, 'DEFERRED', 3, 'IMMEDIATE', 'FALSE'), decode(bitand(ksppiflg, 4), 4, 'FALSE', decode(bitand(ksppiflg / 65536, 3), 0, 'FALSE', 'TRUE')), decode(bitand(ksppstvf, 7), 1, 'MODIFIED', 4, 'SYSTEM_MOD', 'FALSE'), decode(bitand(ksppstvf, 2), 2, 'TRUE', 'FALSE'), decode(bitand(ksppilrmflg / 64, 1), 1, 'TRUE', 'FALSE'), ksppdesc, ksppstcmnt, ksppihash from x$ksppi x, x$ksppcv y where (x.indx = y.indx);
2、授权用户访问隐藏视图(show_hidden_v$parameter)
--conn "/ as sysdba" grant select on show_hidden_v$parameter to chf;
3、建立同义词(v$parameter)
--conn chf/xifenfei(sys下面已经有该同义词) create synonym v$parameter for sys.show_hidden_v$parameter;
4、直接查询隐藏参数
select x.ksppinm name, x.ksppdesc description, y.ksppstvl value, y.ksppstdf isdefault, decode(bitand(y.ksppstvf,7),1,'MODIFIED',4,'SYSTEM_MOD','FALSE') ismod, decode(bitand(y.ksppstvf,2),2,'TRUE','FALSE') isadjusted from sys.x$ksppi x, sys.x$ksppcv y where x.inst_id=userenv('Instance') and y.inst_id=userenv('Instance') and x.indx=y.indx and x.ksppinm like '%_&par%' order by translate(x.ksppinm,'_','');
table()函数用法
因为开发需求需要,存储多个列的结果集,使用table()可以实现
1、创建type
create or replace type t_yqjjrgstj as object ( THSCODE VARCHAR2(96), GSJC VARCHAR2(120) , SSHY VARCHAR2(180), STOCKCODE VARCHAR2(18) , KGLX VARCHAR2(360), GPLX VARCHAR2(180), SSXQ VARCHAR2(60), H_CODE VARCHAR2(30), --额外数据,挑选条件中需要 JYSDM VARCHAR2(36) ,--交易所代码 EJHY VARCHAR2(180),--证监会二级分类 JJKGR VARCHAR2(360)--实际控股人 )
2、实例化type
create or replace type t_jgb_yqjjrgstj as table of t_yqjjrgstj;
3、创建函数
create or replace function f_gjb_yqjjrgstj(in_date in date default sysdate) return t_jgb_yqjjrgstj PIPELINED as v_test_1 t_jgb_yqjjrgstj := t_jgb_yqjjrgstj(); begin for t in (select * from test_yqjbzl) loop pipe row(t_yqjjrgstj(t.thscode, t.gsjc, t.sshy, t.stockcode, t.kglx, t.gplx, t.ssxq, t.h_code, t.jysdm, t.ejhy, t.jjkgr)); end loop; return; end f_gjb_yqjjrgstj;
4、测试
select thscode "同花顺" from table(f_gjb_yqjjrgstj()) where SSXQ='北京';
异构数据库初始化大字段处理
一、source端
SOURCEISTABLE SOURCEDB oracle RMTHOST 127.0.0.1, MGRPORT 7820 RMTFILE D:\ogg\oracle\dirdat\i1 table dbo.t_v; table dbo.t_t;
二、target端
SPECIALRUN END RUNTIME SETENV (NLS_LANG =AMERICAN_AMERICA.ZHS16GBK) userid ogg,password xifenfei EXTFILE D:\ogg\oracle\dirdat\i1 SOURCEDEFS D:\ogg\oracle\dirdef\t_v.def discardfile D:\ogg\oracle\dirtmp\repsz.dsc,append,megabytes 100 MAP "dbo.t_v", target mssql.t_v; MAP "dbo.t_t", target mssql.t_t , colmap ( id = id , text_t = @binary(t_text));
三、执行
extract paramfile dirprm\einit1.prm reportfile dirrpt\einit1.rpt
replicat paramfile dirprm\rinit1.prm reportfile dirrpt\rinit1.rpt
四、试验说明
如果大字段数据库过长,如这里的text字段类型过长是,在l1中有数据,但是target端的数据库中无对应数据,初步分析原因可能有:
1、defgen定义文件中确定文件长度导致
2、target端编码和clob列相关限制有关(可能性不大)
3、goldengate软件内在机制导致,还需要彻底的阅读官网文档
4、现在好像到target端的最终长度为4000byte(根据数据库编码不同区分汉字、字母、数字),在本测试中,如果source端使用ntext,target只能接收1000个汉字,如果是text类型,可以接受1333个汉字。
5、试验环境说明:sql server 2005 to oracle 11g,source端表(id int primary key auto,t_text text),target端(id number primary key,text_t clob)
—出现异常原因已经找到(2011年2月22日23:27:51)
When the size of a large object exceeds 4K, Oracle GoldenGate stores the data in segments within the Oracle GoldenGate trail. The first 4K is stored in the base segment, and the rest is stored in a series of 2K segments. Oracle GoldenGate does not support the filtering, column mapping, or manipulation of large objects of this size. Full Oracle GoldenGate functionality can be used for objects that are 4K or smaller.
大致意思就是当内容超过4k时,就不能使用过滤、列映射、或者操作大字段,当内容等于或者小于4k时,所有的goldengate函数都可以使用。上面问题是当t_text内容大于4k时,不能进行大对象操作。
疑问:那当有数据超过4k该怎么处理
—试验测试(2011年2月23日23:34:13)
初始化后,同步数据库过程中,异构数据库不同列类型(如:mssql中的text到oracle中的clob),也必须使用sourcedefs,使用适当的函数对列类型进行转换(如:colmap ( id = id , t_lob = @binary(t_lob))),对于大于4k的数据,还是和初始化一样不能被处理。该问题等待寻找解决方案