[
https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xingyuan cheng updated FLINK-31530:
-----------------------------------
Description:
The use of OracleCatalog is similar to that of official PostgreSQL, you can
refer to
[https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/jdbc/#jdbc-catalog-for-postgresql].
Use Cases:
{code:java}
CREATE CATALOG ORACLE_CATALOG WITH(
'type' = 'jdbc',
'default-database' = 'orclgps', -- specify the database instance name
'username' = '****', 'password' = '****',
'base-url' = 'jdbc:oracle:thin:@//ip:port' -- do not add the database instance
name
);
SELECT `LINE_NO`, `UP_PASSENGER`, `DOWN_PASSENGER`, `SITE_TIME`, `STATION_NAME`
-- Pay attention to the format of the full table name query data
FROM ORACLE_CATALOG.orclgps.`TMGPS.TM_BUS_PASSENGER_UPDOWN` LIMIT 1; The use of
OracleCatalog is similar to that of official PostgreSQL, you can refer to
https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/
table/jdbc/#jdbc-catalog-for-postgresql.
Use Cases:
CREATE CATALOG ORACLE_CATALOG WITH(
'type' = 'jdbc',
'default-database' = 'orclgps', -- specify the database instance name
'username' = '****', 'password' = '****',
'base-url' = 'jdbc:oracle:thin:@//ip:port' -- do not add the database instance
name
);
SELECT `LINE_NO`, `UP_PASSENGER`, `DOWN_PASSENGER`, `SITE_TIME`, `STATION_NAME`
-- Pay attention to the format of the full table name query data
FROM ORACLE_CATALOG.orclgps.`TMGPS.TM_BUS_PASSENGER_UPDOWN` LIMIT 1; {code}
> For currently commonly used databases, MySQL and Postgres have implemented
> catalogs. Currently, catalogs are implemented based on Oracle
> ----------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-31530
> URL: https://issues.apache.org/jira/browse/FLINK-31530
> Project: Flink
> Issue Type: Improvement
> Reporter: xingyuan cheng
> Priority: Major
> Labels: pull-request-available
>
> The use of OracleCatalog is similar to that of official PostgreSQL, you can
> refer to
> [https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/table/jdbc/#jdbc-catalog-for-postgresql].
> Use Cases:
>
> {code:java}
> CREATE CATALOG ORACLE_CATALOG WITH(
> 'type' = 'jdbc',
> 'default-database' = 'orclgps', -- specify the database instance name
> 'username' = '****', 'password' = '****',
> 'base-url' = 'jdbc:oracle:thin:@//ip:port' -- do not add the database
> instance name
> );
> SELECT `LINE_NO`, `UP_PASSENGER`, `DOWN_PASSENGER`, `SITE_TIME`,
> `STATION_NAME`
> -- Pay attention to the format of the full table name query data
> FROM ORACLE_CATALOG.orclgps.`TMGPS.TM_BUS_PASSENGER_UPDOWN` LIMIT 1; The use
> of OracleCatalog is similar to that of official PostgreSQL, you can refer to
> https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/connectors/
> table/jdbc/#jdbc-catalog-for-postgresql.
> Use Cases:
> CREATE CATALOG ORACLE_CATALOG WITH(
> 'type' = 'jdbc',
> 'default-database' = 'orclgps', -- specify the database instance name
> 'username' = '****', 'password' = '****',
> 'base-url' = 'jdbc:oracle:thin:@//ip:port' -- do not add the database
> instance name
> );
> SELECT `LINE_NO`, `UP_PASSENGER`, `DOWN_PASSENGER`, `SITE_TIME`,
> `STATION_NAME`
> -- Pay attention to the format of the full table name query data
> FROM ORACLE_CATALOG.orclgps.`TMGPS.TM_BUS_PASSENGER_UPDOWN` LIMIT 1; {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
