public String getWriteStatement()

in cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/PersistenceController.java [105:130]

• 26 lines of code
• 5 McCabe index (conditional complexity)

    public String getWriteStatement(String keyspace, String table) {
        String key = keyspace.concat(table);
        String statement = writeStatements.get(key);
        if (statement != null) {
            return statement;
        }
        List<String> cols = getKeyValueColumns();
        StringBuilder colsList = new StringBuilder();
        StringBuilder questionsList = new StringBuilder();
        for (String column : cols) {
            if (colsList.length() != 0) {
                colsList.append(", ");
                questionsList.append(",");
            }
            colsList.append(column);
            questionsList.append("?");
        }
        statement = "insert into " + keyspace + "." + table + " (" +
            colsList.toString() + ") values (" + questionsList.toString() + ")";
        if (persistenceSettings.getTTL() != null) {
            statement += " using ttl " + persistenceSettings.getTTL();
        }
        statement += ";";
        writeStatements.put(key, statement);
        return statement;
    }