ORA-26711: remote table does not contain a primary key constraint
 *Cause:  The master table for remote apply does not constain a primary key
          constraint or the primary key constraint has been disabled.
 *Action: Create a primary key constraint on the master table or enable the
          existing constraint.

SQL> desc DBO.REGIONS@ASD.SUBHI.COM
 Name                                      Null?    Type
 ----------------------------------------- -------- ----------
 a                                         NOT NULL NUMBER(10)

SQL> insert into dbo.regions values(77);

1 row created.

SQL> commit;

Commit complete.

CREATE TABLE regions (a INTEGER primary key)

CREATE PUBLIC DATABASE LINK aaa.subhi.com CONNECT TO
"sa" IDENTIFIED BY "asd" USING 'dg4msql';

conn strmadmin/123;
EXEC DBMS_STREAMS_ADM.SET_UP_QUEUE();

DECLARE 
 ret INTEGER; 
BEGIN 
ret := DBMS_HS_PASSTHROUGH.EXECUTE_IMMEDIATE@aaa.subhi.com ( 
  'drop TABLE "HR"."jobs1"'); 
END; 
/ 
COMMIT;


conn strmadmin/123;

DECLARE 
 ret INTEGER; 
BEGIN 
ret := DBMS_HS_PASSTHROUGH.EXECUTE_IMMEDIATE@aaa.subhi.com ( 
  'CREATE TABLE "HR"."jobs1" ( "JOB_ID" VARCHAR(10), "JOB_TITLE" VARCHAR(35) CONSTRAINT "JOB_TITLE_NN1" NOT NULL , "MIN_SALARY" integer, "MAX_SALARY" integer,CONSTRAINT "JOB_ID_PK1" PRIMARY KEY ("JOB_ID"))'); 
END; 
/ 
COMMIT; 

conn hr/hr

CREATE TABLE "HR"."jobs1" ( "JOB_ID" VARCHAR(10), "JOB_TITLE" VARCHAR(35) CONSTRAINT "JOB_TITLE_NN1" NOT NULL , "MIN_SALARY" integer, "MAX_SALARY" integer,CONSTRAINT "JOB_ID_PK1" PRIMARY KEY ("JOB_ID"))


conn strmadmin/123;

BEGIN
  DBMS_CAPTURE_ADM.PREPARE_TABLE_INSTANTIATION(
    table_name           => 'hr.jobs1',
    supplemental_logging => 'keys');
END;
/


DECLARE
  iscn  NUMBER;   
BEGIN
  iscn := DBMS_FLASHBACK.GET_SYSTEM_CHANGE_NUMBER(); 
DBMS_APPLY_ADM.SET_TABLE_INSTANTIATION_SCN(
    source_object_name    => 'hr.jobs1',
    source_database_name  => 'orcl3',
    instantiation_scn     => iscn,
    apply_database_link   => 'aaa.subhi.com');
END;
/



BEGIN
  DBMS_STREAMS_ADM.ADD_SCHEMA_RULES(
    schema_name    => 'hr',   
    streams_type   => 'capture',
    streams_name   => 'capture_sql',
    queue_name     => 'strmadmin.streams_queue',
    include_dml    => TRUE, 
    include_ddl    => TRUE,
    inclusion_rule => TRUE);
END;
/



BEGIN
  DBMS_APPLY_ADM.CREATE_APPLY(
    queue_name          => 'strmadmin.streams_queue',
    apply_name          => 'apply_sql',
    apply_database_link => 'aaa.subhi.com',
    apply_captured      => TRUE);
END;
/

BEGIN
  DBMS_STREAMS_ADM.ADD_TABLE_RULES(
    table_name      => 'hr.jobs1',
    streams_type    => 'apply', 
    streams_name    => 'apply_sql',
    queue_name      => 'strmadmin.streams_queue',
    include_dml     => TRUE,
    include_ddl     => FALSE,
    source_database => 'orcl3',
    inclusion_rule  => TRUE);
END;
/




BEGIN
  DBMS_APPLY_ADM.SET_PARAMETER(
    apply_name  => 'apply_sql', 
    parameter   => 'disable_on_error', 
    value       => 'N');
END;
/
 
BEGIN
  DBMS_APPLY_ADM.START_APPLY(
    apply_name  => 'apply_sql');
END;
/


BEGIN
  DBMS_CAPTURE_ADM.START_CAPTURE(
    capture_name  => 'capture_sql');
END;