Skip to content
GitLab
Explore
Projects
Groups
Topics
Snippets
Projects
Groups
Topics
Snippets
/
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Register
Sign in
Toggle navigation
Menu
UPSMF
knowledge-platform
Commits
0774af62
Commit
0774af62
authored
4 years ago
by
rheafernandes
Browse files
Options
Download
Patches
Plain Diff
Added fix to circle ci build
parent
c242822c
schema-updates
3.9.0-prod-fix
4.1.0_fixes
AmiableAnil-patch-1
Gcloud_copy
Gcloud_fix
Remove_unwantedCode_Gcloud_fix
actors-test
bulk-upload-comptenecy-mapping
bulk-upload-excelsheet
bulk-upload-test_excel
bulk_upload
code-cleanup
csp-migration
dependabot/maven/platform-core/platform-telemetry/ch.qos.logback-logback-core-1.2.9
dependabot/maven/search-api/search-core/org.apache.httpcomponents-httpclient-4.5.13
knowlg-friday
knowlg-oneclick
local-setup-fix
local-setup-kube
m-4.2.0
master
master-data
org-target-enhancement
patch-1
patch-2
patch-3
poc_bulk_upload
qs-schema
rahul_bulk_upload_postgres
release-3.6.0
release-3.6.0.1
release-3.7.0
release-3.8.0
release-3.9.0
release-4.0.0
release-4.1.0
release-4.10.0
release-4.10.1
release-4.2.0
release-4.3.0
release-4.4.0
release-4.5.0
release-4.6.0
release-4.7.0
release-4.7.0-debug
release-4.8.0
release-4.8.0-debug
release-4.9.0
release-4.9.1
release-5.0.0
release-5.0.1
release-5.1.0
release-5.1.0-content
release-5.2.0
release-5.3.0
revert-718-visiblity-private-api
revert-719-assessment-private-read-api
revert-720-visiblity-public-search-api
revert-721-visiblity-private-search-api
review-4.1.0
s-debug
schema-update-4.0
release-5.2.0_RC2
release-5.2.0_RC1
release-5.1.0_RC1
release-5.0.0_RC2
release-5.0.0_RC1
release-4.10.0_RC2
release-4.10.0_RC1
release-4.9.1_RC1
release-4.9.0_RC8
release-4.9.0_RC7
release-4.9.0_RC6
release-4.9.0_RC5
release-4.9.0_RC4
release-4.9.0_RC3
release-4.9.0_RC2
release-4.9.0_RC1
release-4.8.0_RC5
release-4.8.0_RC4
release-4.8.0_RC3
release-4.8.0_RC2
release-4.8.0_RC1
release-4.7.0_RC6
release-4.7.0_RC5
release-4.7.0_RC4
release-4.7.0_RC3
release-4.7.0_RC2
release-4.7.0_RC1
release-4.6.0_RC2
release-4.6.0_RC1
release-4.5.0_RC2
release-4.5.0_RC1
release-4.4.0_RC6
release-4.4.0_RC5
release-4.4.0_RC4
release-4.4.0_RC3
release-4.4.0_RC2
release-4.4.0_RC1
release-4.3.0_RC10
release-4.3.0_RC9
release-4.3.0_RC8
release-4.3.0_RC7
release-4.3.0_RC6
release-4.3.0_RC5
release-4.3.0_RC4
release-4.3.0_RC3
release-4.3.0_RC2
release-4.3.0_RC1
release-4.2.0_RC13
release-4.2.0_RC12
release-4.2.0_RC11
release-4.2.0_RC10
release-4.2.0_RC9
release-4.2.0_RC8
release-4.2.0_RC7
release-4.2.0_RC6
release-4.2.0_RC5
release-4.2.0_RC4
release-4.2.0_RC3
release-4.2.0_RC2
release-4.2.0_RC1
release-4.1.0_RC13
release-4.1.0_RC12
release-4.1.0_RC11
release-4.1.0_RC10
release-4.1.0_RC9
release-4.1.0_RC8
release-4.1.0_RC7
release-4.1.0_RC6
release-4.1.0_RC5
release-4.1.0_RC4
release-4.1.0_RC3
release-4.1.0_RC2
release-4.1.0_RC1
release-4.0.0_RC9
release-4.0.0_RC8
release-4.0.0_RC7
release-4.0.0_RC6
release-4.0.0_RC5
release-4.0.0_RC4
release-4.0.0_RC3
release-4.0.0_RC2
release-4.0.0_RC1
release-3.9.0_RC12
release-3.9.0_RC11
release-3.9.0_RC10
release-3.9.0_RC9
release-3.9.0_RC8
release-3.9.0_RC7
release-3.9.0_RC6
release-3.9.0_RC5
release-3.9.0_RC4
release-3.9.0_RC3
release-3.9.0_RC2
release-3.9.0_RC1
release-3.8.0_RC9
release-3.8.0_RC8
release-3.8.0_RC7
release-3.8.0_RC6
release-3.8.0_RC5
release-3.8.0_RC4
release-3.8.0_RC3
release-3.8.0_RC2
release-3.8.0_RC1
release-3.7.0_RC1
release-3.6.0_RC5
release-3.6.0_RC4
release-3.6.0_RC3
No related merge requests found
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
ontology-engine/graph-core_2.11/src/main/scala/org/sunbird/graph/external/store/ExternalStore.scala
+8
-6
...cala/org/sunbird/graph/external/store/ExternalStore.scala
ontology-engine/graph-engine_2.11/src/main/scala/org/sunbird/graph/external/store/ExternalStore.scala
+8
-6
...cala/org/sunbird/graph/external/store/ExternalStore.scala
with
16 additions
and
12 deletions
+16
-12
ontology-engine/graph-core_2.11/src/main/scala/org/sunbird/graph/external/store/ExternalStore.scala
+
8
−
6
View file @
0774af62
...
...
@@ -27,12 +27,14 @@ class ExternalStore(keySpace: String , table: String , primaryKey: java.util.Lis
insertQuery
.
value
(
"last_updated_on"
,
new
Timestamp
(
new
Date
().
getTime
))
import
scala.collection.JavaConverters._
for
((
key
,
value
)
<-
request
.
asScala
)
{
if
(
"blob"
.
equalsIgnoreCase
(
propsMapping
.
getOrElse
(
key
,
""
)))
insertQuery
.
value
(
key
,
QueryBuilder
.
fcall
(
"textAsBlob"
,
value
))
else
if
(
"string"
.
equalsIgnoreCase
(
propsMapping
.
getOrElse
(
key
,
""
)))
insertQuery
.
value
(
key
,
JsonUtils
.
serialize
(
request
.
getOrDefault
(
key
,
""
)))
else
insertQuery
.
value
(
key
,
value
)
propsMapping
.
getOrElse
(
key
,
""
)
match
{
case
"blob"
=>
insertQuery
.
value
(
key
,
QueryBuilder
.
fcall
(
"textAsBlob"
,
value
))
case
"string"
=>
request
.
getOrDefault
(
key
,
""
)
match
{
case
value
:
String
=>
insertQuery
.
value
(
key
,
value
)
case
_
=>
insertQuery
.
value
(
key
,
JsonUtils
.
serialize
(
request
.
getOrDefault
(
key
,
""
)))
}
case
_
=>
insertQuery
.
value
(
key
,
value
)
}
}
try
{
val
session
:
Session
=
CassandraConnector
.
getSession
...
...
This diff is collapsed.
Click to expand it.
ontology-engine/graph-engine_2.11/src/main/scala/org/sunbird/graph/external/store/ExternalStore.scala
+
8
−
6
View file @
0774af62
...
...
@@ -28,12 +28,14 @@ class ExternalStore(keySpace: String , table: String , primaryKey: java.util.Lis
insertQuery
.
value
(
"last_updated_on"
,
new
Timestamp
(
new
Date
().
getTime
))
import
scala.collection.JavaConverters._
for
((
key
,
value
)
<-
request
.
asScala
)
{
if
(
"blob"
.
equalsIgnoreCase
(
propsMapping
.
getOrElse
(
key
,
""
)))
insertQuery
.
value
(
key
,
QueryBuilder
.
fcall
(
"textAsBlob"
,
value
))
else
if
(
"string"
.
equalsIgnoreCase
(
propsMapping
.
getOrElse
(
key
,
""
)))
insertQuery
.
value
(
key
,
JsonUtils
.
serialize
(
request
.
getOrDefault
(
key
,
""
)))
else
insertQuery
.
value
(
key
,
value
)
propsMapping
.
getOrElse
(
key
,
""
)
match
{
case
"blob"
=>
insertQuery
.
value
(
key
,
QueryBuilder
.
fcall
(
"textAsBlob"
,
value
))
case
"string"
=>
request
.
getOrDefault
(
key
,
""
)
match
{
case
value
:
String
=>
insertQuery
.
value
(
key
,
value
)
case
_
=>
insertQuery
.
value
(
key
,
JsonUtils
.
serialize
(
request
.
getOrDefault
(
key
,
""
)))
}
case
_
=>
insertQuery
.
value
(
key
,
value
)
}
}
try
{
val
session
:
Session
=
CassandraConnector
.
getSession
...
...
This diff is collapsed.
Click to expand it.
Write
Preview
Supports
Markdown
0%
Try again
or
attach a new file
.
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Save comment
Cancel
Please
register
or
sign in
to comment
Menu
Explore
Projects
Groups
Topics
Snippets