package IS_project2.joeleitao;


import java.io.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;


import static java.lang.System.out;

import java.util.ArrayList;
import java.util.Date;
import java.util.StringTokenizer;
import java.sql.PreparedStatement;

/**
 * Hello world!
 *
 */
public class App
{
	public static Connection conn = null;
	public static PreparedStatement mysql;
	public static ResultSet resultSet;

    public static void main( String[] args ){

    	try {
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/kafka", "root", "brunogrifo96");
		} catch (SQLException ex) {
			// handle any errors
			System.out.println("SQLException: " + ex.getMessage());
			System.out.println("SQLState: " + ex.getSQLState());
			System.out.println("VendorError: " + ex.getErrorCode());
		}
		try {
			conn.setAutoCommit(false);
		} catch (SQLException ex) {
			// conn.rollback();
		}


		try {
			mysql = conn.prepareStatement( "INSERT INTO kafka.Produto(PRECO,QUANTIDADE,NOME,QUANTIDADEINICIAL) VALUES(?,?,?,?);");
			mysql.setInt(1, 3);
			mysql.setInt(2, 4);
			mysql.setString(3, "teste");
			mysql.setInt(4, 123);
			mysql.executeUpdate();
			conn.commit();

		} catch (SQLException e) {
			e.printStackTrace();
			out.println("Something's wrong!!!");
		}

    }
}