Function db_csvcopy

lua/sp.c:3566–3726

}

int db_csvcopy(Lua lua)
{
    luaL_checkudata(lua, 1, dbtypes.db);
    lua_remove(lua, 1);

    SP sp = getsp(lua);

    int rc = 0;
    const char *fname_orig = lua_tostring(lua, 1);
    const char *tablename = NULL;
    const char *cSeparator = ",";
    const char *header = NULL;
    FILE *fp = NULL;
    char *line = NULL;
    size_t len = 0;
    ssize_t read;
    strbuf *columns, *params, *sql;

    char path[PATH_MAX + 1];
    char *fname = comdb2_realpath(fname_orig, path);

    int basedir_len = strlen(thedb->basedir);

    if (fname == NULL) {
        return luaL_error(lua, strerror(errno));
    } else if ((strncmp(thedb->basedir, fname, basedir_len) != 0) || (fname[basedir_len] != '/')) {
        return luaL_error(lua, "File not in database directory");
    }

    if (lua_gettop(lua) >= 2 && !lua_isnil(lua, 2) && !luabb_isnull(lua, 2)) {
       tablename = luabb_tostring(lua, 2);
    } else {
        return luaL_error(lua, "Table name not specified");
    }

    if (lua_gettop(lua) >= 3 && !lua_isnil(lua, 3) && !luabb_isnull(lua, 3)) {
       cSeparator = luabb_tostring(lua, 3);
    }

    if (lua_gettop(lua) >= 4 && !lua_isnil(lua, 4) && !luabb_isnull(lua, 4)) {
       header = luabb_tostring(lua, 4);
    }

    fp = fopen(fname, "r");

    if (fp == NULL) {
        return luaL_error(lua, strerror(errno));
    }

    columns = strbuf_new();
    params = strbuf_new();

    strbuf_append(columns, "(");
    strbuf_append(params, "(");

    if (header == NULL) {
        read = getline(&line, &len, fp);
        header = line;