MySQL Kein DB-Eintrag

[Sc0rP1En]

Hallo Community,

ich arbeite gerade an einer Client /Server Verbindung bei der, der Server Daten mittels EclipseLink in die DB schreibt.

Server

ServerBTS() throws IOException
{
	EntityManagerFactory factory;
	factory = Persistence.createEntityManagerFactory("BTS");
	EntityManager em = factory.createEntityManager();
	em.getTransaction().begin();
	
	System.out.println("BTS-Server started!");
	while (true)
	{
		Socket socket = server.accept();
        thread = new Database(socket,em);
        thread.start();
	}
}

public static void main (String[] args)
{
	try {
		ServerBTS server = new ServerBTS();
		
	}
	catch (IOException e)
	{
		System.out.print(e);
	}
}
}

Database

public class Database extends Thread {

	EntityManager _em;
	Socket _socket;
	double _north;
	double _east;
	
	public Database(Socket socket,EntityManager em)
	{
		this._em = em;
		this._socket = socket;

	}
	
	public void run(){
	 
	int CorHostName=-1;
     ArrayList<String> AlHostNames = new ArrayList<String>();
     AlHostNames.add("Thimo01");
     AlHostNames.add("Thimo02");
     AlHostNames.add("LKW01");
     AlHostNames.add("LKW02");
     
     InetAddress addr = _socket.getInetAddress();
     String hostname = addr.getHostName();
     
     Hostnames:
     for (int i =0; i<AlHostNames.size();i++)
     {
     if (hostname.equals(AlHostNames.get(i)))
      {
    	  CorHostName = i;
    	  break Hostnames;

      }
     }
     
		//Empfang von Doublewerten
		DataInputStream input;
		try {
			input = new DataInputStream(_socket.getInputStream());
			_north = input.readDouble();
			_east = input.readDouble();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

     
     System.out.println(AlHostNames.get(CorHostName));
     System.out.println(CorHostName+"      "+_north+" , "+_east);
     switch (CorHostName)
	{
	case 0:

		 Koordinaten2 koord2 = new Koordinaten2();
		 koord2.setDate(new Date());
		 koord2.setNorth(_north);
		 koord2.setEast(_east);
		 _em.merge(koord2);
//		 _em.getTransaction().commit();
		 break;
		 
	case 1:
		Koordinaten3 koord3 = new Koordinaten3();
		 koord3.setDate(new Date());
		 koord3.setNorth(_north);
		 koord3.setEast(_east);
		 _em.merge(koord3);
//		 _em.getTransaction().commit();
		break;

	default:
	System.out.println("Wrong Hostname");		 
	break;
	}
	}
	
	}

Diese Klasse wird nach dem Server.accept aufgerufen um mehrere Clients afertigen zu können.

Mein Problem ist, dass er nur in die Datenbank schreibt, wenn ich em.transaction.commit(); auch hinzufüge. Leider ist dann aber die Verbindung geschlossen. Ich habe es sowohl mit em.merge() als auch mit em.persist() versucht.

Hat einer eine Idee?

Danke schon im Voraus.

Greets
Sc0rP1En

 

[Marcinek]

Nachdem du eine Transaktion commitet hast, must du eine neue erzeugen.

Oder deine Datenbankverbindung auf autocommit stellen. Wie das in deinem Fall geht kann ich aber nicht sagen.

Dein Code enthält viele Fehler bezüglich der Java Code-Stlye Konvention.

 

[Sc0rP1En]

Danke Marcinek,

aber ist eine Persistenzschicht nicht dafür da, dass stetig eine Verbindung offen ist und man nicht immer wieder eine neue Verbindung aufmachen muss?

Wird der eintrag nicht mit persist() oder merge() in die Datenbank geschrieben und das Commit braucht man garnicht? Denn es hat bei mir auch schon ohne das Commit funktioniert :S

Ist die Style-Konvention eine Vorgabe wie der Code formatiert sein soll? Darum habe ich mich noch nicht gekümmert, denn bin ich noch in der Einlernphase für das schlussendliche Projekt.

Greets
Sc0rP1En

 

[Marcinek]

Du musst das em.getTransaction().begin();

einfach in deinen verarbeitenden Thread packen.

Was Transaktionen sind, welche Vorteile und Nachteile sie haben, kann man in den entprechenden Büchern nachlesen. Das werde ich hier nicht tippen.

Eventuell auch versuchen pro Thread einen eigenen EntityManager packen.

Wenn du das erst lernst, dann ist es umsowichtiger, dass die Basics sitzen. Und wenn du vor hast mit anderen Leuten an einem Code zu arbeiten, wirst du die Style Vereinbarungen zu schätzen wissen.

 

[Sc0rP1En]

Okay Danke ich werde das mal probieren.

Das mit dem Style ist mir klar, habe auch schon mit unformatiertem Code arbeiten müssen und das war kein Spaß. Daran werde ich mich halten!

greets
Sc0rP1En