package mxs1146;

import java.sql.Blob;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.SQLException;

import java.sql.Statement;

import java.sql.Time;

import java.util.Random;

public class MXS1146 {

    public static void main(String[] args) {

        try (Connection connection = DriverManager.getConnection("jdbc:mariadb://192.168.121.164:4008/test?user=skysql&password=skysql")) {

            for (int x = 0; x < 1000; x++) {

                System.out.println(x);

                Statement stmt = connection.createStatement();

                stmt.execute("drop table if exists DOCUMENTS");

                stmt.execute("create table DOCUMENTS (DOCUMENT_ID int, FILENAME varchar(255),"

                        + " REMARKS varchar(255), PARENT_FOLDER_ID int, PREVIEW blob, DOCUMENT blob, "

                        + "IS_FOLDER tinyint, BUZZWORD1 varchar(255), BUZZWORD2 varchar(255), "

                        + "BUZZWORD3 varchar(255), BUZZWORD4 varchar(255), BUZZWORD5 varchar(255), "

                        + "BUZZWORD6 varchar(255), BUZZWORD7 varchar(255), BUZZWORD8 varchar(255), "

                        + "BUZZWORD9 varchar(255), BUZZWORD10 varchar(255), DOCUMENT_TYPE varchar(255), "

                        + "WAS_EXPORTED tinyint, CLIENT_ID int, DOCUMENT_BYTE_SIZE int, "

                        + "PREVIEW_BYTE_SIZE int, IS_SIGNED tinyint, DOCUMENTDATE datetime) ENGINE=BLACKHOLE");

                try (PreparedStatement ps = connection.prepareStatement("INSERT INTO DOCUMENTS "

                        + "(DOCUMENT_ID, FILENAME, REMARKS, PARENT_FOLDER_ID, PREVIEW, DOCUMENT, "

                        + "IS_FOLDER, BUZZWORD1, BUZZWORD2, BUZZWORD3, BUZZWORD4, BUZZWORD5, "

                        + "BUZZWORD6, BUZZWORD7, BUZZWORD8, BUZZWORD9, BUZZWORD10, DOCUMENT_TYPE, "

                        + "WAS_EXPORTED, CLIENT_ID, DOCUMENT_BYTE_SIZE, PREVIEW_BYTE_SIZE, IS_SIGNED, "

                        + "DOCUMENTDATE) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")) {

                    for (int i = 0; i < 1000; i++) {

                        Random r = new Random();

                        byte[] b = new byte[10000];

                        r.nextBytes(b);

                        Blob blob1 = connection.createBlob();

                        Blob blob2 = connection.createBlob();

                        blob1.setBytes(1, b);

                        blob2.setBytes(1, b);

                        ps.setInt(1, 0);

                        ps.setString(2, "some_file.png");

                        ps.setString(3, "Remarks");

                        ps.setInt(4, 1);

                        ps.setBlob(5, blob1);

                        ps.setBlob(6, blob2);

                        ps.setInt(7, 0);

                        ps.setString(8, "Buzzword1");

                        ps.setString(9, "Buzzword2");

                        ps.setString(10, "Buzzword3");

                        ps.setString(11, "Buzzword4");

                        ps.setString(12, "Buzzword5");

                        ps.setString(13, "Buzzword6");

                        ps.setString(14, "Buzzword7");

                        ps.setString(15, "Buzzword8");

                        ps.setString(16, "Buzzword9");

                        ps.setString(17, "Buzzword10");

                        ps.setString(18, "Image");

                        ps.setInt(19, 0);

                        ps.setInt(20, 123);

                        ps.setInt(21, 10000);

                        ps.setInt(22, 10000);

                        ps.setInt(23, 0);

                        ps.setTime(24, new Time(System.currentTimeMillis()));

                        ps.execute();

                    }

                }

            }

        } catch (SQLException ex) {

            System.out.println("SQLException: " + ex.getMessage());

        }

    }

}