5

我有一个小 C++ 问题，我无法通过在线浏览来解决。这是我的代码（提取）：

if(File.is_open()) {
    while(!File.eof())  {
        i++;
        getline(File,Line);
        if(i>=2) {                //Skip Headers
            int CharCount=0;
            for(int CharPosition=0; CharPosition<Line.size(); CharPosition++)                       {
                if(Line[CharPosition]==',') {
                    Length=CharPosition;
                    break;
                }
            }
            NameText=Line.substr(0,Length);
            Path= Path_Folder + "\\" + NameText + ".csv";
            if(!CheckExistance(Path.c_str())) {
                fstream Text_File;
            }
            Text_File.open(Path, fstream::in | fstream::out | fstream::app);
            Text_File<<Line<<"\n";
            Text_File.close();
        }
    }
}

这段代码工作正常，但我想改变它关闭的事实Text_File每次进入 while 循环时都会关闭的事实。

基本上，该程序将一个大输入文件拆分为许多较小的文件。随着我的小文件越来越大，执行变得越来越慢（正常）。然后，我的目标是让所有较小的文件 ( Text_File) 在此 while 循环中打开，并将 fstream 指针（指针？）从一个切换到另一个。

我试图改变为：

...

NameText=Line.substr(0,Length);
Path= Path_Folder + "\\" + NameText + ".csv";

if(!CheckExistance(Path.c_str())) {
    fstream Text_File;
}

if(!Text_File.open()) {
    Text_File.open(Path, fstream::in |fstream::out | fstream::app);
}

Text_File<<Line<<"\n";
\\Text_File.close();

...

但Text_File无论如何，它都在工作NameText。所以我猜测 fstream 的指针Text_File不会改变。那我需要成为什么？休息指针？如何？

谢谢你们！

不确定它是否相关，但我正在使用 Microsoft Visual C++ 2010 Express。另外，我不是一个程序员，无论是教育还是生活，如果你能不用太高级的话解释一下，我将不胜感激。

4

6 回答 6

4

看起来你想在一个对象上玩弄filebufs 。ostream

现在，唯一的障碍是可复制类型ostream或basic_filebuf<char>不可复制类型，因此您不能直接将它们放入映射（按文件名）。这很容易通过创建一个小Holder类型来解决：

struct Holder {
    Holder(std::string const& path) 
        : buf(std::make_shared<std::filebuf>())
    { 
        buf->open(path.c_str(), std::ios::out | std::ios::app);
    }
    std::shared_ptr<std::filebuf> buf;
};

std::map<std::string, Holder> buffers;

现在完整的程序（经过测试）将如下所示：

#include <fstream>
#include <sstream>
#include <iostream>
#include <map>
#include <memory>

const std::string Path_Folder = ".";

int main()
{
    std::istream& File     = std::cin; // just for example
    std::filebuf  dummy;
    std::ostream  TextFile(&dummy);

    struct Holder {
        Holder(std::string const& path) 
            : buf(std::make_shared<std::filebuf>())
        { 
            buf->open(path.c_str(), std::ios::out | std::ios::app);
        }
        std::shared_ptr<std::filebuf> buf;
    };

    std::map<std::string, Holder> buffers;
    int i = 0;

    std::string   Line;
    while(getline(File, Line))
    {
        if (i++<2)
            continue; //Skip Headers

        auto NameText = Line.substr(0, Line.find(','));
        auto Path = Path_Folder + '/' + NameText + ".csv";

        // open, only if not allready opened
        auto found = buffers.find(NameText);
        if (end(buffers) == found)
            found = buffers.insert({ NameText, Path }).first;

        TextFile.rdbuf(found->second.buf.get());

        TextFile << Line << std::endl; // notice implicit std::flush in std::endl
    }

    // all files are automatically closed here
}

另外三个注意事项：

  • buffers当地图超出范围时，文件会自动关闭。
  • rdbuf()如果您不以隐式std::flush（如 with ）结束行，则在像这样切换时可能需要添加显式刷新std::endl。
  • dummy只存在有一个ostream我们可以切换缓冲区的对象

我使用以下输入对此进行了测试：

Header Row #1
Header Row #2
Jack,1,some data
Jill,2,some more data
Jack,3,not reopening :)
Jill,4,jill still receiving output
Romeo,5,someone else reporting

现在，我得到了以下输出：在Coliru现场观看

/tmp$ rm *.csv
/tmp$ make && ./test < input.txt && tail *.csv

g++ -std=c++11 -Wall -g test.cpp -o test
==> Jack.csv <==
Jack,1,some data
Jack,3,not reopening :)

==> Jill.csv <==
Jill,2,some more data
Jill,4,jill still receiving output

==> Romeo.csv <==
Romeo,5,someone else reporting
于 2013-07-28T23:09:38.170 回答
2

注意：看起来您Text_File的超出范围。我猜你在代码的其他地方声明了它。所以，这条线是没用的：

if(!CheckExistance(Path.c_str())){fstream Text_File;}

要访问多个文件流，您可以使用这个利用std::map数据结构的简单类：

#include <iostream>
#include <map>
#include <string>
#include <fstream>

class StreamWriter
{
    typedef std::map<std::string, std::fstream> StreamMap;
    static StreamMap Files;

public:
    static std::fstream& GetFile(const std::string& filename)
    {
        std::fstream& stream = Files[filename];
        if (!stream.is_open())
        {
            stream.open(filename, std::fstream::in
                   | std::fstream::out | std::fstream::app);
        }
        return stream;
    }
};

StreamWriter::StreamMap StreamWriter::Files = StreamWriter::StreamMap();

然后，访问文件很简单：

StreamWriter::GetFile("C:/sample1.txt") << "test";

而已。

于 2013-07-26T19:11:26.807 回答
1

我要做的是使用std::map或std::unordered_map将名称映射到 fstream 对象。

map<string, fstream> files;

...

while(getline(File,Line)) // don't use while(File.eof())
{
    ...

    if( files.count(NameText) == 0 ) // checks for the existence of the fstream object
    {            
        files[NameText].open(Path, fstream::in | fstream::out);
    }

    files[NameText] << Line << "\n";
}

请参阅此处了解为什么我更改了 while 循环的条件。

您的操作系统可能无法同时打开这么多文件。也许你可以尝试这样的事情。

在您的地图旁边，保留一个打开文件的名称列表。每次需要写入文件时，首先在列表中搜索它，将其删除并添加到列表的前面。如果它不存在，只需将其添加到列表的前面。检查以确保文件已打开。如果不是，请尝试打开它。如果打开失败，则一个一个地从列表后面删除项目，关闭该项目对应的文件，然后再次尝试打开当前文件。重复直到打开文件成功。

这样做将确保最常写入的文件位于列表的前面并保持打开状态。写入频率较低的文件将移到后面，并最终被关闭。在列表中搜索文件不是最优的 (O(n))，但由于我们在这里处理写入文件，这是一个更昂贵的操作，你不应该注意到任何类型的性能命中。

于 2013-07-26T18:52:09.093 回答
0

您正在尝试重用Text_Filefstream。为此，您必须在close()完成对 csv 文件的写入后执行刷新流。请看这个问题：C++ can I use fstream to open and write multiple files?

另外：这是我对这个问题的谷歌搜索：http: //goo.gl/Oy5KKM

于 2013-07-26T18:45:59.577 回答
0

请注意，这Text_File是一个变量，与所有变量一样，您可以拥有多个具有相同类型的变量。如果您需要管理多个不同的文件，您甚至可以std::fstream在任何标准容器中使用，例如std::vector或std::map. 此外，您应该考虑将代码分解为更小更易于管理的部分。例如，您可以创建一个以 anstd::fstream&作为参数的函数。这允许程序的其余部分控制std::fstream&在任何给定时间使用哪个。我强烈建议您查看不同的设计选项来帮助组织您的代码。

于 2013-07-26T18:58:07.747 回答
0

如前所述，存在检查语句无效。也许你的意图是做这样的事情：

if(!CheckExistance(Path.c_str())) {
    fstream Text_File;

    Text_File.open(Path, fstream::in | fstream::out | fstream::app);
    Text_File<<Line<<"\n";
    Text_File.close();
}

if 语句范围内的 fstream 将隐藏您必须在外部范围内拥有的 fstream。此外，关闭是可选的 - 当流超出范围时将关闭。

于 2013-07-26T19:35:42.790 回答