| 404 | } |
| 405 | |
| 406 | public DDF sql2ddf(String sqlCommand) throws DDFException { |
| 407 | try { |
| 408 | // sqlCommand = sqlCommand.replace("@this", this.getTableName()); |
| 409 | sqlCommand = sqlCommand.replace("@this", "{1}"); |
| 410 | sqlCommand = String.format(sqlCommand, "{1}"); |
| 411 | SQLDataSourceDescriptor sqlDS = new SQLDataSourceDescriptor(sqlCommand, |
| 412 | null, null,null, this.getUUID().toString()); |
| 413 | return this.getManager().sql2ddf(sqlCommand, null, sqlDS); |
| 414 | // return this.getManager().sql2ddf(sqlCommand); |
| 415 | } catch (Exception e) { |
| 416 | throw new DDFException(String.format("Error executing queries for ddf %s", this.getTableName()), e); |
| 417 | } |
| 418 | } |
| 419 | |
| 420 | // ///// Aggregate operations |
| 421 | |