Function dbtable_copyfrom

lua/sp.c:2506–2560

}

static int dbtable_copyfrom(Lua lua)
{
    SP sp = getsp(lua);

    dbtable_t *tbl1, *tbl2;
    const char *where_clause = NULL;

    int nargs = lua_gettop(lua);
    if (nargs > 3) {
        return luabb_error(lua, sp, "expected 2 arguments found %d %s", nargs,
                           __func__);
    }

    luaL_checkudata(lua, 1, dbtypes.dbtable);
    tbl1 = (dbtable_t *)lua_topointer(lua, 1);

    luaL_checkudata(lua, 2, dbtypes.dbtable);
    tbl2 = (dbtable_t *)lua_topointer(lua, 2);

    if (lua_isstring(lua, 3)) where_clause = (const char *)lua_tostring(lua, 3);

    char t1n1[MAXTABLELEN], t1sep[2], t1n2[MAXTABLELEN];
    query_tbl_name(tbl1->table_name, t1n1, t1sep, t1n2);

    char t2n1[MAXTABLELEN], t2sep[2], t2n2[MAXTABLELEN];
    query_tbl_name(tbl2->table_name, t2n1, t2sep, t2n2);

    strbuf *sql = strbuf_new();
    if (where_clause)
        strbuf_appendf(
            sql, "insert into %s%s\"%s\" select * from %s%s\"%s\" where %s",
            t1n1, t1sep, t1n2, t2n1, t2sep, t2n2, where_clause);
    else
        strbuf_appendf(sql, "insert into %s%s\"%s\" select * from %s%s\"%s\"",
                       t1n1, t1sep, t1n2, t2n1, t2sep, t2n2);

    db_reset(lua);
    sqlite3_stmt *stmt = NULL;
    int rc = lua_prepare_sql(sp, strbuf_buf(sql), &stmt);
    strbuf_free(sql);
    if (rc != 0) {
        return rc;
    }

    lua_begin_step(sp->clnt, sp, stmt);
    while ((rc = sqlite3_maybe_step(sp->clnt, stmt)) == SQLITE_ROW) {
        lua_another_step(sp->clnt, stmt, rc);
    }
    lua_end_step(sp->clnt, sp, stmt);

    sqlite3_finalize(stmt);

    lua_pushinteger(lua, 0); /* Success return code. */
    return 1;
}

static int dbtable_name(Lua L)
{