Форум программистов [Powered by Invision Power Board]

Код

    public void defaultSqlInsert(Collection objects) {
        for (Iterator it = objects.iterator(); it.hasNext(); ) {
            PropertyBasedObject pbo = (PropertyBasedObject) it.next();
            pbo.put(ID, getIdByTable(pbo.getTableName()));
            String insert = "insert into " + pbo.getTableName() + "(";
            String insertAdd = " values(";
            Collection values = new Vector();
            String[] fields = pbo.getAllSqlFields();

            boolean isFirst = true;
            for (int i = 0; i < fields.length; i++) {
                if (pbo.containsKey(fields[i])) {
                    if (!isFirst) {
                        insert += ", ";
                        insertAdd += ", ";
                    }
                    else isFirst = false;
                    insert += fields[i];
                    insertAdd += "?";
                    values.add(pbo.get(fields[i]));
                }
            }
            insert += ")";
            insertAdd += ")";
            insert += insertAdd;

            try {
                PreparedStatement preparedStatement = p3isDB.prepareStatement(insert);
                for (int i = 1; i <= values.size(); i++) {
                    Object obj = ((Vector) values).get(i - 1);
                    if (obj.getClass().equals(String.class))
                        preparedStatement.setString(i, (String) obj);
                    else if (obj.getClass().equals(Long.class))
                        preparedStatement.setLong(i, ((Long) obj).longValue());
                    else if (obj.getClass().equals(Double.class))
                        preparedStatement.setDouble(i, ((Double) obj).doubleValue());
                    else if (obj.getClass().equals(Boolean.class))
                        preparedStatement.setBoolean(i, ((Boolean) obj).booleanValue());
                    else if (obj.getClass().equals(PImageBlob.class))
                        preparedStatement.setBlob(i, (Blob) obj);
                    else if (obj.getClass().equals(java.util.Date.class))
                        preparedStatement.setDate(i, new Date (((java.util.Date) obj).getTime()));
                }
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }