package dbHelpers;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

import model.Grocery;

public class AddQuery {

	public Connection connection;

	public AddQuery(String dbName, String uname, String pwd) {
		String url = "jdbc:mysql://localhost:3306/" + dbName;

		try {
			Class.forName("com.mysql.jdbc.Driver").newInstance();
			this.connection = DriverManager.getConnection(url, uname, pwd);
		} catch (InstantiationException | IllegalAccessException | ClassNotFoundException | SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public void doAdd(Grocery grocery) {
		String query = "insert into products (SKU, ProductType, Flavor, Cost, Price, Quantity) values (?, ?, ?, ?, ?, ?)";

		try {
			PreparedStatement ps = connection.prepareStatement(query);
			ps.setString(1, grocery.getSku());
			ps.setString(2, grocery.getProductType());
			ps.setString(3, grocery.getFlavor());
			ps.setDouble(4, grocery.getCost());
			ps.setDouble(5, grocery.getPrice());
			ps.setInt(6, grocery.getQuantity());

			ps.executeUpdate();

		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}