db_init_kotlin.kt

package database

import java.sql.*
import java.util.Properties

class Db_init(){

    val username: String? = "root"
    val password: String? = "a"
    var conn: Connection? = null


    fun sql_conn(){
        val connectionProps = Properties()
        connectionProps.put("user", username)
        connectionProps.put("password", password)
        Class.forName("com.mysql.jdbc.Driver").newInstance()
        conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/btc_dekrypt?useSSL=false",connectionProps)

    }

    fun create_tables():Int{
        println("***********************creating tables***********************")
        sql_conn()
        var stmt:Statement? = null
        var resultset:ResultSet? = null
        stmt = conn!!.createStatement()
        var query = ""
        var table_conflict = ""
        var temp  = 0
        try {
            table_conflict = "select 1 from address_master limit 1"
            resultset = stmt!!.executeQuery(table_conflict)
            println("table address_master Exist")
        }
//            if (resultset!!.next()){
//                println("table exist")
//            }
        catch (e: Exception) {
        println("table address_master doesnt exist")
        query = "create table address_master (address varchar(35),priv_key varchar(100), user varchar(20));"
        temp = stmt!!.executeUpdate(query)
        println("created table address_master")

        }


        try {
            table_conflict = "select 1 from tx_details limit 1"
            resultset = stmt!!.executeQuery(table_conflict)
            println("table tx_details exist")
        }
        catch (e: Exception) {
                println("table named tx_details doesnt exist")
                query = "create table tx_details (txid varchar(100)," +
                        "currency varchar(45), user_name varchar(45),to_address varchar(35),value varchar(20)," +
                        "timestamp varchar(45),user varchar(20),confirmations varchar(1),flag varchar(1),vout varchar(2));"
                temp = stmt!!.executeUpdate(query)
                println("created table tx_Details")

            }


        try {
            table_conflict = "select 1 from user_master limit 1"
            resultset = stmt!!.executeQuery(table_conflict)
            println("table user_master exist")
        }
        catch (e: Exception) {
                    println("table user_master doesnt exist")
                 query = "create table user_master (user_name varchar(45),token varchar(100),notification_url varchar(50));"
                temp = stmt!!.executeUpdate(query)
                println("created table user_master")
            }







        return 1

    }



}