The code example shared in the following post worked, Execute Dynamic Query within BPM Data Directive - #6 by asmar