Пользовательский поток

Ответ 1

Пользовательское назначение для ostream означает реализацию вашего собственного ostreambuf. Если вы хотите, чтобы ваш streambuf фактически буферизовался (т.е. Не подключался к базе данных после каждого символа), самый простой способ сделать это - создать класс, наследующий от std::stringbuf. Функция только, которую вам нужно переопределить, это метод sync(), который вызывается всякий раз, когда поток очищается.

class MyBuf : public std::stringbuf
{
public:
    virtual int sync() {
        // add this->str() to database here
        // (optionally clear buffer afterwards)
    }
};

Затем вы можете создать std::ostream с помощью своего буфера:

MyBuf buff;
std::ostream stream(&buf)

Большинство людей советовали не перенаправлять поток в базу данных, но они проигнорировали мое описание, что в базе данных в основном есть одно поле blob, где весь текст будет. В редких случаях я могу отправить данные в другое поле. Этому могут способствовать пользовательские атрибуты, понятные моему потоку. Например:

MyStream << "Some text " << process_id(1234) << "more text" << std::flush

В приведенном выше коде будет создана запись в базе данных с помощью:

blob: 'Some text more text'
process_id: 1234

process_id() - метод, возвращающий структуру ProcessID. Затем, в реализации моего ostream, у меня есть operator<<(ProcessID const& pid), который хранит идентификатор процесса до тех пор, пока он не будет написан. Отлично работает!

Ответ 2

Самый простой способ - наследовать std::streambuf и переопределить только два метода:

• std::streamsize xsputn(const char_type* s, std::streamsize n) - добавить данный буфер с размером, указанным в вашем внутреннем буфере, std::string например;
• int_type overflow(int_type c) - добавить один char в свой внутренний буфер.

Ваш streambuf может быть сконструирован из всего, что вам нужно (например, для подключения к базе данных). После добавления чего-либо во внутренний буфер вы можете попытаться разбить его на строки и нажать что-нибудь в БД (или просто буферизовать SQL-запросы для выполнения позже).

Чтобы использовать его: просто прикрепите streambuf к любому std::ostream с помощью конструктора.

Simple! Я сделал что-то подобное для вывода строк в syslog - все работает отлично с любым пользовательским operator<< для пользовательских классов.

Ответ 3

my2c - Я думаю, что вы занимаетесь этим неправильно. Поток может показаться приятной идеей, но вам понадобится способ указать конец строки тоже (а потом что, если кто-то забудет?) Я бы предложил что-то вроде того, как работают Java PreparedStatements и партии, так как в предоставлении набора методов, которые принимают типы и индекс столбца, затем "пакетный" метод, который явно дает понять, что вы действительно выполняете эту строку, а затем выполняете, чтобы вставить пакет.

Любая операция, основанная на потоке, будет полагаться на тип (обычно), чтобы указать, какой столбец заполняется, но что, если у вас есть два ints? IMO, как пользователь, не кажется естественным способом вставки записей в базу данных...

Ответ 4

Чтобы добавить новый источник или назначение ввода/вывода символов в механизм iostreams, вы должны создать новый класс streambuf. Задача классов буфера потока - связываться с "внешним устройством", которое будет хранить символы и предоставлять средства буферизации.

Проблема с использованием iostreams для связи с вашей базой данных заключается в том, что таблица базы данных не соответствует концепции последовательности символов. Немного похоже на толкание круглого штифта в квадратное отверстие. A streambuf работает только с символами. Это единственное, что когда-либо было представлено ему. Это означает, что streambuf должен проанализировать переданный ему поток символов, чтобы найти разделители полей и записей. Если вы решите пойти по этому маршруту, я предскажу, что вы в конце концов напишите конвертер CSV-to-SQL в своем streambuf, чтобы заставить его работать.

Вероятно, вам будет лучше, только добавив несколько перегрузок operator<< к вашим классам. Вы можете посмотреть на рамки Qt для идей здесь. Они также имеют возможность использовать operator<< для добавления элементов в коллекции и т.д.