import "reflect-metadata"
import { DataSource } from "../../../src/data-source/DataSource"
import {
    closeTestingConnections,
    createTestingConnections,
    reloadTestingDatabases,
} from "../../utils/test-utils"
import { Table } from "../../../src/schema-builder/table/Table"
import { DriverUtils } from "../../../src/driver/DriverUtils"

describe("query runner > rename table", () => {
    let connections: DataSource[]
    before(async () => {
        connections = await createTestingConnections({
            entities: [__dirname + "/entity/*{.js,.ts}"],
            schemaCreate: true,
            dropSchema: true,
        })
    })
    beforeEach(() => reloadTestingDatabases(connections))
    after(() => closeTestingConnections(connections))

    it("should correctly rename table and revert rename", () =>
        Promise.all(
            connections.map(async (connection) => {
                // CockroachDB and Spanner does not support renaming constraints and removing PK.
                if (
                    connection.driver.options.type === "cockroachdb" ||
                    connection.driver.options.type === "spanner"
                )
                    return

                const queryRunner = connection.createQueryRunner()

                const sequenceQuery = (name: string) => {
                    return `SELECT COUNT(*) FROM information_schema.sequences WHERE sequence_schema = 'public' and sequence_name = '${name}'`
                }

                // check if sequence "faculty_id_seq" exist
                if (connection.driver.options.type === "postgres") {
                    const facultySeq = await queryRunner.query(
                        sequenceQuery("faculty_id_seq"),
                    )
                    facultySeq[0].count.should.be.equal("1")
                }

                let table = await queryRunner.getTable("faculty")

                await queryRunner.renameTable(table!, "question")
                table = await queryRunner.getTable("question")
                table!.should.be.exist

                // check if sequence "faculty_id_seq" was renamed to "question_id_seq"
                if (connection.driver.options.type === "postgres") {
                    const facultySeq = await queryRunner.query(
                        sequenceQuery("faculty_id_seq"),
                    )
                    const questionSeq = await queryRunner.query(
                        sequenceQuery("question_id_seq"),
                    )
                    facultySeq[0].count.should.be.equal("0")
                    questionSeq[0].count.should.be.equal("1")
                }

                await queryRunner.renameTable("question", "answer")
                table = await queryRunner.getTable("answer")
                table!.should.be.exist

                // check if sequence "question_id_seq" was renamed to "answer_id_seq"
                if (connection.driver.options.type === "postgres") {
                    const questionSeq = await queryRunner.query(
                        sequenceQuery("question_id_seq"),
                    )
                    const answerSeq = await queryRunner.query(
                        sequenceQuery("answer_id_seq"),
                    )
                    questionSeq[0].count.should.be.equal("0")
                    answerSeq[0].count.should.be.equal("1")
                }

                await queryRunner.executeMemoryDownSql()

                table = await queryRunner.getTable("faculty")
                table!.should.be.exist

                // check if sequence "answer_id_seq" was renamed to "faculty_id_seq"
                if (connection.driver.options.type === "postgres") {
                    const answerSeq = await queryRunner.query(
                        sequenceQuery("answer_id_seq"),
                    )
                    const facultySeq = await queryRunner.query(
                        sequenceQuery("faculty_id_seq"),
                    )
                    answerSeq[0].count.should.be.equal("0")
                    facultySeq[0].count.should.be.equal("1")
                }

                await queryRunner.release()
            }),
        ))

    it("should correctly rename table with all constraints depend to that table and revert rename", () =>
        Promise.all(
            connections.map(async (connection) => {
                // CockroachDB and Spanner does not support renaming constraints and removing PK.
                if (
                    connection.driver.options.type === "cockroachdb" ||
                    connection.driver.options.type === "spanner"
                )
                    return

                const queryRunner = connection.createQueryRunner()

                let table = await queryRunner.getTable("post")

                await queryRunner.renameTable(table!, "renamedPost")
                table = await queryRunner.getTable("renamedPost")
                table!.should.be.exist

                // should successfully drop pk if pk constraint was correctly renamed.
                await queryRunner.dropPrimaryKey(table!)

                // MySql does not support unique constraints
                if (
                    !DriverUtils.isMySQLFamily(connection.driver) &&
                    !(connection.driver.options.type === "sap")
                ) {
                    const newUniqueConstraintName =
                        connection.namingStrategy.uniqueConstraintName(table!, [
                            "text",
                            "tag",
                        ])
                    let tableUnique = table!.uniques.find((unique) => {
                        return !!unique.columnNames.find(
                            (columnName) => columnName === "tag",
                        )
                    })
                    tableUnique!.name!.should.be.equal(newUniqueConstraintName)
                }

                await queryRunner.executeMemoryDownSql()

                table = await queryRunner.getTable("post")
                table!.should.be.exist

                await queryRunner.release()
            }),
        ))

    it("should correctly rename table with custom schema and database and all its dependencies and revert rename", () =>
        Promise.all(
            connections.map(async (connection) => {
                // CockroachDB and Spanner does not support renaming constraints and removing PK.
                if (
                    connection.driver.options.type === "cockroachdb" ||
                    connection.driver.options.type === "spanner"
                )
                    return

                const queryRunner = connection.createQueryRunner()
                let table: Table | undefined

                let questionTableName: string = "question"
                let renamedQuestionTableName: string = "renamedQuestion"
                let categoryTableName: string = "category"
                let renamedCategoryTableName: string = "renamedCategory"

                // create different names to test renaming with custom schema and database.
                if (connection.driver.options.type === "mssql") {
                    questionTableName = "testDB.testSchema.question"
                    renamedQuestionTableName =
                        "testDB.testSchema.renamedQuestion"
                    categoryTableName = "testDB.testSchema.category"
                    renamedCategoryTableName =
                        "testDB.testSchema.renamedCategory"
                    await queryRunner.createDatabase("testDB", true)
                    await queryRunner.createSchema("testDB.testSchema", true)
                } else if (
                    connection.driver.options.type === "postgres" ||
                    connection.driver.options.type === "sap"
                ) {
                    questionTableName = "testSchema.question"
                    renamedQuestionTableName = "testSchema.renamedQuestion"
                    categoryTableName = "testSchema.category"
                    renamedCategoryTableName = "testSchema.renamedCategory"
                    await queryRunner.createSchema("testSchema", true)
                } else if (DriverUtils.isMySQLFamily(connection.driver)) {
                    questionTableName = "testDB.question"
                    renamedQuestionTableName = "testDB.renamedQuestion"
                    categoryTableName = "testDB.category"
                    renamedCategoryTableName = "testDB.renamedCategory"
                    await queryRunner.createDatabase("testDB", true)
                }

                await queryRunner.createTable(
                    new Table({
                        name: questionTableName,
                        columns: [
                            {
                                name: "id",
                                type: DriverUtils.isSQLiteFamily(
                                    connection.driver,
                                )
                                    ? "integer"
                                    : "int",
                                isPrimary: true,
                                isGenerated: true,
                                generationStrategy: "increment",
                            },
                            {
                                name: "name",
                                type: "varchar",
                            },
                        ],
                        indices: [{ columnNames: ["name"] }],
                    }),
                    true,
                )

                await queryRunner.createTable(
                    new Table({
                        name: categoryTableName,
                        columns: [
                            {
                                name: "id",
                                type: DriverUtils.isSQLiteFamily(
                                    connection.driver,
                                )
                                    ? "integer"
                                    : "int",
                                isPrimary: true,
                                isGenerated: true,
                                generationStrategy: "increment",
                            },
                            {
                                name: "questionId",
                                type: "int",
                                isUnique: true,
                            },
                        ],
                        foreignKeys: [
                            {
                                columnNames: ["questionId"],
                                referencedTableName: questionTableName,
                                referencedColumnNames: ["id"],
                            },
                        ],
                    }),
                    true,
                )

                // clear sqls in memory to avoid removing tables when down queries executed.
                queryRunner.clearSqlMemory()

                await queryRunner.renameTable(
                    questionTableName,
                    "renamedQuestion",
                )
                table = await queryRunner.getTable(renamedQuestionTableName)
                const newIndexName = connection.namingStrategy.indexName(
                    table!,
                    ["name"],
                )
                table!.indices[0].name!.should.be.equal(newIndexName)

                await queryRunner.renameTable(
                    categoryTableName,
                    "renamedCategory",
                )
                table = await queryRunner.getTable(renamedCategoryTableName)
                const newForeignKeyName =
                    connection.namingStrategy.foreignKeyName(
                        table!,
                        ["questionId"],
                        "question",
                        ["id"],
                    )
                table!.foreignKeys[0].name!.should.be.equal(newForeignKeyName)

                await queryRunner.executeMemoryDownSql()

                table = await queryRunner.getTable(questionTableName)
                table!.should.be.exist

                table = await queryRunner.getTable(categoryTableName)
                table!.should.be.exist

                await queryRunner.release()
            }),
        ))
})