common.cpp

#include "common.h"
#include <iostream>
#include <fstream>
#include <vector>


std::string currentDatabase = "default_db";  
std::map<std::string, std::map<std::string, Table>> databases;


void init() {
    if (!std::filesystem::exists(workPath)) {
        std::filesystem::create_directory(workPath);
        std::cout << "Created work directory: " << workPath << std::endl;
    } else {
        std::cout << "Work directory already exists: " << workPath << std::endl;
    }

   
    currentDatabase = "";

   
    std::string defaultDbPath = getDatabasePath("default");
    if (!std::filesystem::exists(defaultDbPath)) {
        std::filesystem::create_directory(defaultDbPath);
        std::cout << "Created default database directory: " << defaultDbPath << std::endl;
    }

   
    flushMetaFile("default");
}


bool fileExists(const std::string& filePath) {
    return std::filesystem::exists(filePath);
}

void flushMetaFile(const std::string& dbName) {
    
    std::string dbPath = getDatabasePath(dbName);

   
    if (!std::filesystem::exists(dbPath)) {
        std::filesystem::create_directory(dbPath);
        std::cout << "Created database directory: " << dbPath << std::endl;
    }

 
    std::string metaFilePath = dbPath + "/meta.dat";
    std::ofstream ofs(metaFilePath);
    if (ofs.is_open()) {
        ofs << "Database: " << dbName << "\n";
        ofs.close();
        std::cout << "Meta file created successfully: " << metaFilePath << std::endl;
    } else {
        std::cerr << "Error: Failed to write meta file for database " << dbName << std::endl;
    }
}


std::string getDatabasePath(const std::string& dbName) {
    return std::string(workPath) + "/" + dbName;
}


std::string getTablePath(const std::string& dbName, const std::string& tableName) {
    return getDatabasePath(dbName) + "/" + tableName; 
}

std::string getCsvFilePath(const std::string& dbName, const std::string& tableName) {
   if (tableName.empty()) {
        std::cerr << "[ERROR] getCsvFilePath: tableName is empty!" << std::endl;
    }

    std::string path = "/tmp/jzwsqlbase/" + dbName + "/" + tableName + ".csv";
    
    return path;

}

std::string getSchemaFilePath(const std::string& dbName, const std::string& tableName) {
   return "/tmp/jzwsqlbase/" + dbName + "/" + tableName + ".schema";
}


std::string getCurrentDatabasePath() {
    if (currentDatabase.empty()) {
        throw std::runtime_error("No database selected. Please use 'USE DATABASE <name>' to select a database.");
    }
    return getDatabasePath(currentDatabase); 
}

void printResult(const std::vector<std::vector<std::string>>& result) {
    for (const auto& row : result) {
        for (const auto& field : row) {
            std::cout << field << " ";
        }
        std::cout << std::endl;
    }
}