/******************************************************************************
 * $Id$
 *
 * Project:  OpenGIS Simple Features Reference Implementation
 * Purpose:  Test dynamic loading of SQLite Virtual Table module using OGR
 *layers Author:   Even Rouault, even dot rouault at spatialys.com
 *
 ******************************************************************************
 * Copyright (c) 2012, Even Rouault <even dot rouault at spatialys.com>
 *
 * SPDX-License-Identifier: MIT
 ****************************************************************************/

#ifdef HAVE_SPATIALITE
#ifdef SPATIALITE_AMALGAMATION
/*
/ using an AMALGAMATED version of SpatiaLite
/ a private internal copy of SQLite is included:
/ so we are required including the SpatiaLite's
/ own header
/
/ IMPORTANT NOTICE: using AMALAGATION is only
/ useful on Windows (to skip DLL hell related oddities)
*/
#include <spatialite/sqlite3.h>
#else
/*
/ You MUST NOT use AMALGAMATION on Linux or any
/ other "sane" operating system !!!!
*/
#include "sqlite3.h"
#endif
#else
#include "sqlite3.h"
#endif

#include <stdio.h>
#include <stdlib.h>

#undef NDEBUG
#include <assert.h>

#ifndef _MSC_VER
#include <unistd.h>
#endif

#if _MSC_VER
#define snprintf _snprintf
#endif

int main(int argc, char *argv[])
{
    sqlite3 *db = NULL;
    char *pszErrMsg = NULL;
    char **papszResult = NULL;
    int nRowCount = 0, nColCount = 0;
    int rc;
    char szBuffer[256];

    if (argc < 2 || argc > 4)
    {
        fprintf(stderr, "Usage: test_load_virtual_ogr libgdal.so|gdalXX.dll "
                        "[datasource_name] [layer_name]\n");
        exit(1);
    }

    sqlite3_open("tmp.db", &db);
    if (db == NULL)
    {
        fprintf(stderr, "cannot open DB.\n");
        exit(1);
    }

    rc = sqlite3_enable_load_extension(db, 1);
    if (rc != SQLITE_OK)
    {
        fprintf(stderr, "sqlite3_enable_load_extension() failed\n");
        sqlite3_close(db);
        unlink("tmp.db");
        exit(1);
    }

    rc = sqlite3_load_extension(db, argv[1], NULL, &pszErrMsg);
    if (rc != SQLITE_OK)
    {
        fprintf(stderr, "sqlite3_load_extension(%s) failed: %s\n", argv[1],
                pszErrMsg);
        sqlite3_free(pszErrMsg);
        sqlite3_close(db);
        unlink("tmp.db");
        exit(1);
    }

    rc = sqlite3_get_table(db, "SELECT ogr_version()", &papszResult, &nRowCount,
                           &nColCount, &pszErrMsg);

    if (rc == SQLITE_OK && nRowCount == 1 && nColCount == 1)
    {
        printf("SELECT ogr_version() returned : %s\n", papszResult[1]);
    }
    else
    {
        fprintf(stderr, "SELECT ogr_version() failed: %s\n", pszErrMsg);
        sqlite3_free(pszErrMsg);
        sqlite3_close(db);
        unlink("tmp.db");
        exit(1);
    }
    sqlite3_free_table(papszResult);

    if (argc >= 3)
    {
        if (argc == 3)
        {
            snprintf(szBuffer, sizeof(szBuffer),
                     "CREATE VIRTUAL TABLE foo USING VirtualOGR('%s')",
                     argv[2]);
        }
        else
        {
            snprintf(
                szBuffer, sizeof(szBuffer),
                "CREATE VIRTUAL TABLE foo USING VirtualOGR('%s', 0, '%s', 1)",
                argv[2], argv[3]);
        }

        rc = sqlite3_exec(db, szBuffer, NULL, NULL, &pszErrMsg);
        if (rc != SQLITE_OK)
        {
            fprintf(stderr, "%s failed: %s\n", szBuffer, pszErrMsg);
            sqlite3_free(pszErrMsg);
            sqlite3_close(db);
            unlink("tmp.db");
            exit(1);
        }
        else
        {
            if (argc == 3)
                printf("Managed to open '%s'\n", argv[2]);
            else
                printf("Managed to open '%s':'%s'\n", argv[2], argv[3]);

            assert(SQLITE_OK ==
                   sqlite3_exec(db,
                                "CREATE TABLE spy_table (spy_content VARCHAR)",
                                NULL, NULL, NULL));

            assert(SQLITE_OK ==
                   sqlite3_exec(db, "CREATE TABLE regular_table (bar VARCHAR)",
                                NULL, NULL, NULL));

            assert(
                SQLITE_OK ==
                sqlite3_exec(
                    db,
                    "CREATE TRIGGER spy_trigger INSERT ON regular_table BEGIN "
                    "INSERT OR REPLACE INTO spy_table (spy_content) "
                    "SELECT OGR_STYLE FROM foo; END;",
                    NULL, NULL, NULL));

            sqlite3_close(db);
            db = NULL;

            sqlite3_open("tmp.db", &db);
            if (db == NULL)
            {
                fprintf(stderr, "cannot reopen DB.\n");
                unlink("tmp.db");
                exit(1);
            }

            assert(SQLITE_OK == sqlite3_enable_load_extension(db, 1));

            assert(SQLITE_OK ==
                   sqlite3_load_extension(db, argv[1], NULL, NULL));

            pszErrMsg = NULL;
            assert(SQLITE_OK !=
                   sqlite3_exec(
                       db, "INSERT INTO regular_table (bar) VALUES ('bar')",
                       NULL, NULL, &pszErrMsg));

            fprintf(stderr, "Expected error. We got : %s\n", pszErrMsg);

            sqlite3_free(pszErrMsg);
        }
    }

    sqlite3_close(db);
    unlink("tmp.db");

    return 0;
}