Swing DB Zugriff mit JProgressBar?!

[ElJarno]

Hi Leute,
in meinem jetztigen Programm geht es darum, dass ich größere Datenmengen in eine DB speichere. Um den Benutzer zu informieren wie weit die Abarbeitung ist, wollte ich ein JProgressBar implementieren. Aufgrund des bekannten Problems mit der Sichtbarkeit und der Threads wollte ich nun irgendwie die Schleifenabarbeitung in ein Thread-Objekt auslagern Hier mal der ürsprüngliche Code:

	public void insertBinaerDaten(String dateiID, int packetGroesse, File datei)
			throws SQLException, IOException {
		BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(datei));
		long dateiGroesse = datei.length();
		int partNr = 0;
		if (dateiGroesse <= Integer.MAX_VALUE) {
			int bytesLeft = (int) dateiGroesse;
			this.edStatusBar.getProgressBar2().setMinimum(0);
			this.edStatusBar.getProgressBar2().setMaximum(bytesLeft);
			
			
			while (bytesLeft > 0) {
				String objid = ObjectID.getOBJID(199);

				java.sql.PreparedStatement ps = this.getConnection().prepareStatement(
						"INSERT into " + paketDatenTabelle + " VALUES(?,?,?,?,?)");
				ps.setString(1, objid);
				ps.setString(2, dateiID);
				ps.setInt(3, partNr);
				ps.setInt(4, packetGroesse);
				ps.setBinaryStream(5, inputStream, packetGroesse);
				ps.execute();
				ps.close();
				partNr += 1;
				bytesLeft -= packetGroesse;
				this.edStatusBar.getProgressBar2().setValue(
						this.edStatusBar.getProgressBar2().getMaximum() - bytesLeft);
			}
			inputStream.close();
		} else {
			this.edStatusBar.getProgressBar2().setValue(0);
			throw new IOException("Datei ist zu groß! " + datei.getName());
		}
	}

Und hier der Versuch die Schleife in den Thread auszulagern.

	public void insertBinaerDaten(String dateiID, int packetGroesse, File datei)
			throws SQLException, IOException {
		BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(datei));
		long dateiGroesse = datei.length();
		int partNr = 0;
		if (dateiGroesse <= Integer.MAX_VALUE) {
			int bytesLeft = (int) dateiGroesse;
			this.edStatusBar.getProgressBar2().setMinimum(0);
			this.edStatusBar.getProgressBar2().setMaximum(bytesLeft);

			new Thread(new Runnable() {
				public void run() {
					while (bytesLeft > 0) {
						String objid = ObjectID.getOBJID(199);

						java.sql.PreparedStatement ps = getConnection().prepareStatement(
								"INSERT into " + paketDatenTabelle + " VALUES(?,?,?,?,?)");
						ps.setString(1, objid);
						ps.setString(2, dateiID);
						ps.setInt(3, partNr);
						ps.setInt(4, packetGroesse);
						ps.setBinaryStream(5, inputStream, packetGroesse);
						ps.execute();
						ps.close();
						partNr += 1;
						bytesLeft -= packetGroesse;

						SwingUtilities.invokeLater(new Runnable() {
							public void run() {
								edStatusBar.getProgressBar2().setValue(
										edStatusBar.getProgressBar2().getMaximum() - bytesLeft);
							}
						});

					}
					inputStream.close();
				}
			}).start();
		} else {
			this.edStatusBar.getProgressBar2().setValue(0);
			throw new IOException("Datei ist zu groß! " + datei.getName());
		}
	}

Problem hierbei ist nun die Sichtbarkeit der lokalen Variablen in der Methode die ja in dem Thread-Objekt nicht Sichtbar sind, wollte jetzt nicht unbedingt alle lokalen Variablen global zwischenspeichern. Was noch viel problematischer dabei ist, dass man die Exceptions nicht weiterreichen kann. Und da weiß ich wriklich nicht wie ich das Problem lösen soll.
Ein kongrete Code-Hilfe würde mir echt weiter helfen da ich mich mit Threads noch nicht wirklich befasst habe.

Gruß Jan

 

[Niki]

mach die Variablen final bzw. vor dem Thread verwende zusätzliche final Variablen. so z.B:

int i = 0;
i=i+10;

//usw....

final int x = i;
new Thread(new Runnable(){
  public void run(){
    //hier kann x verwendet, jedoch nicht verändert werden!
  }
}).start();

 

[ElJarno]

Oke stimmt. Aber was ist mit der Exceptions Geschicht würd die ungern in dem Thread abfangen bzw. brauch ich die in den anderen Methoden. Konkret. Ich schreibe die Datenpakete in eine Tabelle und die Kopfdaten dazu(Dateityp,Größe etc.) in eine andere Tabelle. Wenn jetzt nun eine Exception beim Schreiben der Daten in die Datentabelle ausgelöst wird, lösche ich den Datensatz für die kopfdaten wieder aus der Tabelle. Gibts ne andere Möglichkeit aus dem Thread heraus sowas auszulösen als über das Weiterreichen der Exception mittels Throw.

Gruß Jan

 

[Michael...]

Ich schreibe die Datenpakete in eine Tabelle und die Kopfdaten dazu(Dateityp,Größe etc.) in eine andere Tabelle. Wenn jetzt nun eine Exception beim Schreiben der Daten in die Datentabelle ausgelöst wird, lösche ich den Datensatz für die kopfdaten wieder aus der Tabelle. Gibts ne andere Möglichkeit aus dem Thread heraus sowas auszulösen als über das Weiterreichen der Exception mittels Throw.

Mir ist Dein Problem nicht ganz klar. Warum schreibst Du die Kopfdaten nicht unmittelbar vor oder nach den Daten in die Datenbank. Wenn Du die Kopfdaten nach den Daten in die Datenbank schreibst, werden diese bei auftreten eines Fehlers erst gar nicht geschrieben. Werden die Kopfdaten zuerst angelegt, kannst Du ja beim Auftreten eines Fehlers ein rollback auf der Datenbank aufrufen, im Erfolgsfall ein commit - dabei darf selbstverständlich kein autocommit o.ä. gesetzt sein.

 

[ElJarno]

Das mit dem Commit und Rollback habe ich bisher in der java.sql.connection Klasse nicht gefunden. Außerdem erst alle Datenmengen zu sammeln und zum Schluss erst zu commiten würde wieder das Problem von zu viel Speichernutzung nach sich ziehen. wie gesagt es handelt sich ja um große Datenmengen. Und die Exception im Thread muss ich ja über cathc abfangen. Sprich der Code laüft ja ganz normal weiter also wird auch der Kopf-DS angelegt selbst wenn ich es hinterher mache.
Hier mal die Thread-Klasse die ich jetzt Probeweise erstellt habe.

package com.ed.jl.DB;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.sql.SQLException;

import javax.swing.SwingUtilities;

import com.ed.bp.ObjectIDManager.ObjectID;
import com.ed.jl.EDToolBar.EDStatusBar;
import com.ed.jl.MySQL.DBConnectMySQL;

public class InsertBinaerDaten extends DBConnectMySQL implements Runnable {
	public final static String paketDatenTabelle = "DATEIEN_BINAER_PAKETE";
	private String dateiID;
	private int packetGroesse;
	private File datei;
	private int bytesLeft;
	private EDStatusBar edStatusBar;

	public InsertBinaerDaten(String dateiID, int packetGroesse, File datei, EDStatusBar edStatusBar) {
		this.dateiID = dateiID;
		this.packetGroesse = packetGroesse;
		this.datei = datei;
		this.edStatusBar = edStatusBar;
	}

	public void run() {
		try {
			this.setConnection();
			this.test();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			this.closeConnection();
		}
	}

	private void test() throws IOException, SQLException {
		BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(datei));
		long dateiGroesse = datei.length();
		int partNr = 0;
		if (dateiGroesse <= Integer.MAX_VALUE) {
			bytesLeft = (int) dateiGroesse;
			edStatusBar.getProgressBar2().setMinimum(0);
			edStatusBar.getProgressBar2().setMaximum(bytesLeft);
			while (bytesLeft > 0) {
				String objid = ObjectID.getOBJID(199);

				java.sql.PreparedStatement ps = getConnection().prepareStatement(
						"INSERT into " + paketDatenTabelle + " VALUES(?,?,?,?,?)");
				ps.setString(1, objid);
				ps.setString(2, dateiID);
				ps.setInt(3, partNr);
				ps.setInt(4, packetGroesse);
				ps.setBinaryStream(5, inputStream, packetGroesse);
				ps.execute();
				ps.close();
				partNr += 1;
				bytesLeft -= packetGroesse;

//				SwingUtilities.invokeLater(new Runnable() {
//					public void run() {
						edStatusBar.getProgressBar2().setValue(
								edStatusBar.getProgressBar2().getMaximum() - bytesLeft);
//					}
//				});

			}
			inputStream.close();
		} else {
			edStatusBar.getProgressBar2().setValue(0);
			throw new IOException("Datei ist zu groß! " + datei.getName());
		}
	}
}

Und hier der Aufruf:

			InsertBinaerDaten insert = new InsertBinaerDaten(dateiID, packetGroesse, datei,
					this.edStatusbar);
			Thread thr = new Thread(insert);
			thr.start();

Habe hier nun auch noch das Problem dass wenn ich verusche auf den insert InvokeAndWait anzuwenden, dass ich hier auch eine Exception bekomme. Ne Idee?

Danke schon mal für die schnelle Hilfe bis jetzt:toll:

 

[Michael...]

Hab jetzt nicht alles durchgelesen

Das mit dem Commit und Rollback habe ich bisher in der java.sql.connection Klasse nicht gefunden.

Sicherlich kann man das commit bzw. rollback auch per Statement auf der Datenbank ausführen lassen.

Außerdem erst alle Datenmengen zu sammeln und zum Schluss erst zu commiten würde wieder das Problem von zu viel Speichernutzung nach sich ziehen. wie gesagt es handelt sich ja um große Datenmengen.

??? Was meinst Du mit Sammeln und Speichernutzung? Du schiebst die Daten ja in die Datenbank - in der Umgebung muss ja genügend Speicher zur Verfügung stehen

Und die Exception im Thread muss ich ja über cathc abfangen. Sprich der Code laüft ja ganz normal weiter also wird auch der Kopf-DS angelegt selbst wenn ich es hinterher mache.

Du kannst ja die genauso Kopfdaten im Thread - z.B. nach der while Schleife - anlegen

 

[ElJarno]

Oke werd mal veruschen den ganzen quatsch in Threads auszulagern. Und wie ist das jetzt mit dem InvokeAndWait?

 

[Michael...]

Oke werd mal veruschen den ganzen quatsch in Threads auszulagern.

Ich meinte nicht in Threads auslagern, sondern im selben Thread in dem Du die Daten in die DB schreibst zum Schluss noch die Kopfdaten in der DB abzulegen.

Und wie ist das jetzt mit dem InvokeAndWait?

Keine Ahnung was Du mit dem InvokeAndWait vor hast?

 

[ElJarno]

Hi,
habs jetzt aber hinbekommen. Hab einfach die in der Hierarchie oberset Methode in einen Thread gepackt und alles andere so belassen wies war. Also im Prinzip in die Listener-Methode den Thread miteingebaut.

Gruß Jan