Как отправить значения данных в базу данных?

Question

Я пытаюсь создать свою собственную версию концепции интеллектуального холодильника, которая по существу отправляет взвешенную стоимость продуктового продукта на внешнюю USB-весы (для моего примера я буду использовать коробку из 6 яиц). Он будет хранить 6 яиц в таблице базы данных MySQL с именем «холодильник», и каждый раз, когда яйцо удаляется, он добавляет одно в таблицу базы данных «Список покупок». Таблица списка покупок будет взаимодействовать с API для онлайн-магазинов (я использую API Tesco: https://devportal.tescolabs.com/products/56c73300d73fa303ed060001).. Я добился успехов в этом, пока не смог определить вес яиц, чтобы распечатать «Изменения в весе»). (Как показано в моем основном классе, вставленном ниже), как только вес яиц окажется между массивом значений, которые я установил. По сути, я застрял в следующей части проекта, которая записывает значения в таблицы базы данных каждый раз, когда изменяется вес У меня есть соединение с базой данных и запрос, который вставляет значения яиц, когда вес совпадает с целым числом EggsWeight, но я хочу, чтобы база данных последовательно обновляла количественные значения в соответствии с изменением веса. Есть ли у кого-нибудь какие-либо рекомендации или предложения? о том, как идти об этом? Любая обратная связь будет оценена.

import java.io.Console;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.usb.UsbConfiguration;
import javax.usb.UsbDevice;
import javax.usb.UsbDeviceDescriptor;
import javax.usb.UsbEndpoint;
import javax.usb.UsbException;
import javax.usb.UsbHostManager;
import javax.usb.UsbHub;
import javax.usb.UsbInterface;
import javax.usb.UsbPipe;
import javax.usb.UsbServices;
import javax.usb.event.UsbPipeDataEvent;
import javax.usb.event.UsbPipeErrorEvent;
import javax.usb.event.UsbPipeListener;

public class UsbScale implements UsbPipeListener {

    private final UsbDevice device;
    private UsbInterface iface;
    private UsbPipe pipe;
    private byte[] data = new byte[6];

    private UsbScale(UsbDevice device) {
        this.device = device;
    }

    public static void main(String[] args) throws UsbException {

        UsbScale scale = UsbScale.findScale();
        scale.open();
        try {
            for (boolean i = true; i; i = true) {
                scale.syncSubmit();
            }
        } finally {
            scale.close();
        }
    }

    public static UsbScale findScale() throws UsbException {
        UsbServices services = UsbHostManager.getUsbServices();
        UsbHub rootHub = services.getRootUsbHub();
        // Dymo M5 Scale:
        UsbDevice device = findDevice(rootHub, (short) 0x0922, (short) 0x8003);
        // Dymo M25 Scale:
        if (device == null) {
            device = findDevice(rootHub, (short) 0x0922, (short) 0x8005);
        }
        if (device == null) {
            return null;
        }
        return new UsbScale(device);
    }

    private static UsbDevice findDevice(UsbHub hub, short vendorId, short productId) {
        for (UsbDevice device : (List<UsbDevice>) hub.getAttachedUsbDevices()) {
            UsbDeviceDescriptor desc = device.getUsbDeviceDescriptor();
            if (desc.idVendor() == vendorId && desc.idProduct() == productId) {
                return device;
            }
            if (device.isUsbHub()) {
                device = findDevice((UsbHub) device, vendorId, productId);
                if (device != null) {
                    return device;
                }
            }
        }
        return null;
    }

    private void open() throws UsbException {
        UsbConfiguration configuration = device.getActiveUsbConfiguration();
        iface = configuration.getUsbInterface((byte) 0);
        // this allows us to steal the lock from the kernel
        iface.claim(usbInterface -> true);
        final List<UsbEndpoint> endpoints = iface.getUsbEndpoints();
        pipe = endpoints.get(0).getUsbPipe(); // there is only 1 endpoint
        pipe.addUsbPipeListener(this);
        pipe.open();
    }

    private void syncSubmit() throws UsbException {
        pipe.syncSubmit(data);
    }

    public void close() throws UsbException {
        pipe.close();
        iface.release();
    }

    @Override
    public void dataEventOccurred(UsbPipeDataEvent upde) {

        boolean empty = data[1] == 2;
        boolean overweight = data[1] == 6;
        boolean negative = data[1] == 5;
        boolean grams = data[2] == 2;
        int scalingFactor = data[3];
        int weight = (data[4] & 0xFF) + (data[5] << 8);

        // int phoneWeights[] = new int[5];
        // int minWeight = 142;
        //int previous weight=0;

        boolean EggsOnScale = false;
        int[] EggsWeight = { 440, 460 };
        int[] OneEgg = { 60, 75 };
        int count = 0;
        int oldweight=0;

        //oldweight = weight;
        if (oldweight == weight) {
            // do nothing
        } else {
            System.out.println("Weight Changes");
            /* write DB


            //if (weight < oldweight){
            //then something was taken off
             * 
             * remove equivalent amount of eggs from db.fridge.

            //if(db.frdige == 0 eggs){
                //order eggs
            }

            if(weight > oldweight){
                somebody put eggs in the fridge. 
            }
            *
            *
            *


        }*/
            oldweight=weight;
        }

        if (weight != oldweight) {
            while (count <= 5000) {
                count++;
            }
            while (count < 5)
                weight = count++;
        /*
         for(int i=0, i=Length(phoneWeights); i++) { phoneWeights[i] = minweight+i; }
         */

        /*
         * System.out.println(String.format("Weight = %,.1f%s", scaleWeight(weight,
         * scalingFactor), grams ? "g" : "oz"));
         */

        System.out.println("My Weight: " + weight);
        /*if(newweight != oldweight) {
            oldweight = newweight;
            write to db shopping list;
        }*/

        if(EggsWeight[0] <= weight && weight <= EggsWeight[1]) {
            EggsOnScale = true;
            System.out.println("6 Eggs on scale");
            // write one phone to table in db.
            try {
                // create a mysql database connection
                String myDriver = "com.mysql.jdbc.Driver";
                String myUrl = "jdbc:mysql://localhost:3306/smartfridge?autoReconnect=true&useSSL=false";
                Class.forName(myDriver);
                Connection conn = DriverManager.getConnection(myUrl, "root", "admin");

                // the mysql insert statement
                String query = " insert into fridge (name, UnitOfSale, ContentsQuantity, department, AverageSellingUnitWeight)"
                        + " values (?, ?, ?, ?, ?)";

                // create the mysql insert preparedstatement
                PreparedStatement preparedStmt = conn.prepareStatement(query);
                preparedStmt.setString(1, "Eggs");
                preparedStmt.setInt(2, 1);
                preparedStmt.setInt(3, 6);
                preparedStmt.setString(4, "Milk, Butter & Eggs");
                preparedStmt.setBoolean(5, EggsOnScale);

                // execute the preparedstatement
                preparedStmt.execute();

            } catch (Exception e) {
                //e.printStackTrace();
            }
        } else{
            /*if(EggsWeight[0] - OneEgg[0] <= weight && weight <= EggsWeight[1] - OneEgg[1]) {
                String query =" update fridge set ContentsQuantity = ContentsQuantity -1 where name ='Eggs' and ContentsQuantity > 0 ";
                //System.out.println(ContentsQuantity + "Eggs On Scale");*/
                oldweight = weight;
            }
        }
    }
    private double scaleWeight(int weight, int scalingFactor) {
        return weight * Math.pow(10, scalingFactor);
    }

    @Override
    public void errorEventOccurred(UsbPipeErrorEvent upee) {
        Logger.getLogger(UsbScale.class.getName()).log(Level.SEVERE, "Scale Error", upee);
    }
}