diff options
Diffstat (limited to 'apps/SoilMoistureIo.cpp')
| -rw-r--r-- | apps/SoilMoistureIo.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/apps/SoilMoistureIo.cpp b/apps/SoilMoistureIo.cpp index 983427c..d184eab 100644 --- a/apps/SoilMoistureIo.cpp +++ b/apps/SoilMoistureIo.cpp @@ -99,12 +99,12 @@ void JsonSampleOutputStream::write(Sample values) { stream << doc << endl; } -SqlSampleOutputStream::SqlSampleOutputStream(ostream &stream) : - stream(stream), filterFields(false) { +SqlSampleOutputStream::SqlSampleOutputStream(ostream &stream, string table_name) : + stream(stream), table_name(table_name), filter_fields(false) { } -SqlSampleOutputStream::SqlSampleOutputStream(ostream &stream, vector<string> fields) : - stream(stream), fields(fields), filterFields(true) { +SqlSampleOutputStream::SqlSampleOutputStream(ostream &stream, string table_name, vector<string> fields) : + stream(stream), table_name(table_name), fields(fields), filter_fields(true) { } void SqlSampleOutputStream::write(Sample values) { @@ -113,7 +113,7 @@ void SqlSampleOutputStream::write(Sample values) { fs.reserve(1024); vs.reserve(1024); - if (filterFields) { + if (filter_fields) { auto i = fields.begin(); while (i != fields.end()) { @@ -151,7 +151,7 @@ void SqlSampleOutputStream::write(Sample values) { } } - stream << "INSERT INTO (" << fs << ") VALUES(" << vs << ");" << endl; + stream << "INSERT INTO " << table_name << "(" << fs << ") VALUES(" << vs << ");" << endl; } void CsvParser::process(mutable_buffers_1 buffer) { |