Skip to content
This repository was archived by the owner on Oct 26, 2023. It is now read-only.

Commit 5cca961

Browse files
committed
Added support for transaction config
1 parent f71beeb commit 5cca961

File tree

1 file changed

+8
-6
lines changed

1 file changed

+8
-6
lines changed

src/index.js

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -131,12 +131,12 @@ export async function neo4jgraphql(
131131
result = await session.writeTransaction(async tx => {
132132
const result = await tx.run(query, cypherParams);
133133
return extractQueryResult(result, resolveInfo.returnType);
134-
});
134+
}, context.transactionConfig);
135135
} else {
136136
result = await session.readTransaction(async tx => {
137137
const result = await tx.run(query, cypherParams);
138138
return extractQueryResult(result, resolveInfo.returnType);
139-
});
139+
}, context.transactionConfig);
140140
}
141141
} finally {
142142
await session.close();
@@ -333,8 +333,8 @@ export const assertSchema = ({
333333
console.table(recordsJSON);
334334
}
335335
return result;
336-
})
337-
)
336+
}),
337+
context.transactionConfig)
338338
.finally(() => session.close());
339339
};
340340
return executeQuery(driver);
@@ -363,7 +363,8 @@ export const searchSchema = async ({
363363
);
364364
}
365365
return true;
366-
})
366+
}),
367+
context.transactionConfig
367368
);
368369
if (!dropResult) {
369370
await session.close();
@@ -382,7 +383,8 @@ export const searchSchema = async ({
382383
);
383384
}
384385
return true;
385-
})
386+
}),
387+
context.transactionConfig
386388
)
387389
.finally(() => session.close());
388390
}

0 commit comments

Comments
 (0)