thecodingmachine / database.tdbm

                $types = [];

                $escapedDbRowData = [];

                foreach ($dbRowData as $columnName => $value) {

                    $columnDescriptor = $tableDescriptor->getColumn($columnName);

                    $types[] = $columnDescriptor->getType();

                    $escapedDbRowData[$this->connection->quoteIdentifier($columnName)] = $value;

                }

                $this->connection->insert($tableName, $escapedDbRowData, $types);

                $escapedDbRowData = [];

                $escapedPrimaryKeys = [];

                foreach ($dbRowData as $columnName => $value) {

                    $columnDescriptor = $tableDescriptor->getColumn($columnName);

                    $types[] = $columnDescriptor->getType();

                    $escapedDbRowData[$this->connection->quoteIdentifier($columnName)] = $value;

                }

                foreach ($primaryKeys as $columnName => $value) {

                    $columnDescriptor = $tableDescriptor->getColumn($columnName);

                    $types[] = $columnDescriptor->getType();

                    $types[] = $columnDescriptor->getType();

                    $escapedDbRowData[$this->connection->quoteIdentifier($columnName)] = $value;

                }

                foreach ($primaryKeys as $columnName => $value) {

                    $columnDescriptor = $tableDescriptor->getColumn($columnName);

                    $types[] = $columnDescriptor->getType();

                    $escapedPrimaryKeys[$this->connection->quoteIdentifier($columnName)] = $value;

                }

                $this->connection->update($tableName, $escapedDbRowData, $escapedPrimaryKeys, $types);

                    $types = [];

                    $escapedFilters = [];

                    foreach ($filters as $columnName => $value) {

                        $columnDescriptor = $tableDescriptor->getColumn($columnName);

                        $types[] = $columnDescriptor->getType();

                        $escapedFilters[$this->connection->quoteIdentifier($columnName)] = $value;

                    }

                    $this->connection->insert($pivotTableName, $escapedFilters, $types);