package com.company;

import java.io.*;
import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class Main {

    public static void main(String[] args) {

        File folder = new File("C:\\My Projects\\NOT ACTIVE\\Steps_qonun_TJ\\0_0\\QonunhoTXT\\Codeks\\qonunho\\");
        File[] listOfFiles = folder.listFiles();

        for (File file : listOfFiles) {
            if (file.isFile()) {
                System.out.println(file.getName());
                String fff="C:\\My Projects\\NOT ACTIVE\\Steps_qonun_TJ\\0_0\\QonunhoTXT\\Codeks\\qonunho\\"+file.getName();

                System.out.println(fff);
//                ************************************************************


                InputStream is = null;
                try {


                    is = new FileInputStream(fff);
                } catch (FileNotFoundException e) {
                    e.printStackTrace();
                }
                BufferedReader buf = new BufferedReader(new InputStreamReader(is));
                String line = null;
                try {
                    line = buf.readLine();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                StringBuilder sb = new StringBuilder(); while(line != null){ sb.append(line).append("\n");
                    try {
                        line = buf.readLine();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }

                String fileAsString = sb.toString();
                System.out.println("Contents : " + fileAsString +"Contents > " );

                //****************************INSERT TO SQLITE***********************************************
                String url1 = "jdbc:sqlite:C://db.db";
                Connection conn9 = null;
                try {
                    conn9 = DriverManager.getConnection(url1);
                } catch (SQLException e) {
                    //  System.out.println(e.getMessage());
                }
              //  String sql = "INSERT INTO warehouses(name,capacity) VALUES(?,?)";
                String sql = "INSERT INTO db(qn,sub) VALUES(?,?)";



                try (
                            PreparedStatement pstmt = conn9.prepareStatement(sql)
                ) {
                    pstmt.setString(1, fileAsString);
                    pstmt.setString(2,"0") ;

                    pstmt.executeUpdate();
                } catch (SQLException e) {
                    System.out.println(e.getMessage());
                }




                //*******************END*********INSERT TO SQLITE***********************************************

            }
        }


    }
}