diff -r 04db6ccd6c48 -r 9335cf31c0f2 java/sql-dk/src/info/globalcode/sql/dk/SQLCommandNumbered.java --- a/java/sql-dk/src/info/globalcode/sql/dk/SQLCommandNumbered.java Sun Dec 22 22:02:44 2013 +0100 +++ b/java/sql-dk/src/info/globalcode/sql/dk/SQLCommandNumbered.java Sun Dec 22 23:31:55 2013 +0100 @@ -17,8 +17,11 @@ */ package info.globalcode.sql.dk; +import static info.globalcode.sql.dk.Functions.notNull; import java.sql.Connection; import java.sql.PreparedStatement; +import java.sql.SQLException; +import java.util.List; /** * @@ -26,13 +29,28 @@ */ public class SQLCommandNumbered extends SQLCommand { - @Override - public PreparedStatement prepareStatement(Connection c) { - throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates. + private List parameters; + + public SQLCommandNumbered(COMMAND_TYPE commandType, String query, List parameters) { + super(commandType, query); + this.parameters = parameters; } @Override - public void parametrize(PreparedStatement ps) { - throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates. + public PreparedStatement prepareStatement(Connection c) throws SQLException { + return c.prepareStatement(getQuery()); + } + + @Override + public void parametrize(PreparedStatement ps) throws SQLException { + int i = 1; + for (Parameter p : notNull(parameters)) { + ps.setObject(i++, p.getValue(), p.getType()); + } + } + + @Override + public List getParameters() { + return parameters; } }