yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-11-09 23:40:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixes #9673 - Oracle casting error (#9682)

Browse Source 
* fix (profiler): oracle profiler datatype error

* fix (profiler): linting

* fix: reorder connection type to default to db schema
This commit is contained in:
Teddy 2023-01-11 19:46:10 +01:00 committed by GitHub
parent 903209bc70
commit 41ce2406a4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ingestion/src/metadata/orm_profiler/orm/functions/sum.py
View File

@ -60,6 +60,13 @@ def _(element, compiler, **kw):
return f"SUM({proc})" return f"SUM({proc})"
@compiles(SumFn, Dialects.Oracle)
def _(element, compiler, **kw):
"""Oracle casting"""
proc = compiler.process(element.clauses, **kw)
return f"SUM(CAST({proc} AS NUMBER))"
@compiles(SumFn, Dialects.IbmDbSa) @compiles(SumFn, Dialects.IbmDbSa)
@compiles(SumFn, Dialects.Db2) @compiles(SumFn, Dialects.Db2)
def _(element, compiler, **kw): def _(element, compiler, **kw):

4
openmetadata-spec/src/main/resources/json/schema/entity/services/connections/database/oracleConnection.json
View File

@ -76,10 +76,10 @@
"description": "Connect with oracle by either passing service name or database schema name.", "description": "Connect with oracle by either passing service name or database schema name.",
"oneOf": [ "oneOf": [
{ {
"$ref": "#/definitions/OracleServiceName" "$ref": "#/definitions/OracleDatabaseSchema"
}, },
{ {
"$ref": "#/definitions/OracleDatabaseSchema" "$ref": "#/definitions/OracleServiceName"
} }
] ]
}, },