1 package com.imcode.db.commands;
2
3 import com.imcode.db.DatabaseConnection;
4 import com.imcode.db.DatabaseException;
5 import org.apache.commons.lang.StringUtils;
6
7 public class InsertIntoTableDatabaseCommand extends ColumnValuesDatabaseCommand {
8
9 public InsertIntoTableDatabaseCommand(String tableName, Object[][] columnNamesAndValues) {
10 super(tableName, columnNamesAndValues);
11 }
12
13 public Object executeOn(DatabaseConnection connection) throws DatabaseException {
14 String sqlPlaceHolders = "?" + StringUtils.repeat(",?", columnNames.length - 1);
15 return connection.executeUpdateAndGetGeneratedKey("INSERT INTO "+tableName+" ( "+ StringUtils.join(columnNames, ", ")+" ) VALUES ("+sqlPlaceHolders+")", columnValues) ;
16 }
17 }