Skip to content

Commit f4b7335

Browse files
committed
use parameterized query for getEdgeProperties
1 parent f1326f5 commit f4b7335

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/NeptuneSchema.js

+3-2
Original file line numberDiff line numberDiff line change
@@ -221,10 +221,11 @@ function addUpdateEdgeProperty(edgeName, name, value) {
221221

222222

223223
async function getEdgeProperties(edge) {
224-
let query = `MATCH ()-[n:${edge.label}]->() RETURN properties(n) as properties LIMIT ${SAMPLE}`;
224+
let query = `MATCH ()-[n]->() WHERE n = $label RETURN properties(n) as properties LIMIT $sample`;
225+
let parameters = `{"label": "${edge.label}", "sample": ${SAMPLE}}`;
225226
loggerLog(`Getting properties for edge: ${query}`);
226227
try {
227-
let response = await queryNeptune(query);
228+
let response = await queryNeptune(query, parameters);
228229
let result = response.results;
229230
result.forEach(e => {
230231
Object.keys(e.properties).forEach(key => {

0 commit comments

Comments
 (0)