[Java] Problema ad inserire dati in un database

[e-commerce84]

Salve ragazzi,
allora mi trovo un po' in difficoltà perchè in una web application che stò sviluppando devo usare un metodo di business che inserisce i dati in un database facendo uso di jdbc (i dati sono inseriti in un form all'utente e devono essere inseriti nel db)

Il fatto è che i metodi di business non li ho scritti io, l'altra persona è abbastanza irreperibile e sono piuttosto disperato...vi spiego come funziona il giro e qual'è il mio problema...vediamo se qualcuno riesce ad illuminarmi:

Ho 2 oggetti da inserire come record in 2 differenti tabelle del mio database, questi ogetti sono:

1) AnagBase anagBaseToUpdate che rappresenta un'anagrafica di base dell'utente (contiene dati come: nome, cognome, compagnia).
Tale oggetto è già presente come record in una tabella di un db MySql chiamata entities_anag_base

2) AnagPf anagPfToUpdate che rappresenta un'anagrafica persona fisica e contiene ulteriori dati anagrafici come data di nascita, luogo di nascita, sesso, etcetc.
Tale oggetto è rappresentato sul DB da una tabella chiamta entities_anag_pf ed ogni suo record deve essere legato con una foreign key ad un'oggetto esistente in entities_anag_base. Al momento tale tabella è VUOTA, non ci sono oggetti

Il mio problema è il seguente:

1) Per prima cosa in un metodo di una mia classe di front end mi vado a recuperare i 2 oggetti anagBaseToUpdate ed anagPfToUpdate dall'oggetto che rappresenta il valori inseriti nel mio form:

// Recupera dal form l'oggetto AnagBase da aggiornare:
			AnagBase anagBaseToUpdate = changeDatiPersonaliForm.getAnagBase();
			
			// Recupera dal form l'oggetto AnagPf da aggiornare:
			AnagPf anagPfToUpdate = changeDatiPersonaliForm.getAnagPf();

E fin quì tutto ok...li recupera tranqullamente

Poi subito dopo vado ad aggiornare l'anagrafica di base nel database, facendo così:

// Aggiorna l'anagrafica di base nel database:
			AnagBase updatedAnagBase = fidsAnagBaseManager.updateAnagBase(anagBaseToUpdate);
			boolean executedUpdateAnagBase = updatedAnagBase != null;

Ed anche quì...viene aggiornata...

Subito dopo invece voglio INSERIRE un nuovo record nella tabella entities_anag_pf con i valori contenuti in anagPf (inseriti dall'utente nel form), quidi faccio così:

// Aggiorna l'anagrafica persone fisiche nel database:
			AnagPf updatedAnagPf = fidsAnagBaseManager.insertAnagPf(anagBaseToUpdate, anagPfToUpdate);
			boolean executedUpdateAnagPf = updatedAnagPf != null;

Ecco,
a questo punto si schianta e dà il seguente errore:


ERROR: com.sogeit.fids.webfids.actions.DatiPersonaliActions - com.mysema.query.QueryException: Caught MySQLIntegrityConstraintViolationException for insert into entities_anag_base(COMPANY_NAME, CREATED_BY, CREATION_DATE, ENTITY_AB_PK, FIRST_NAME, LAST_NAME, LAST_UPDATE, MODIFIED_BY, VOC_ENTITY_CATEGORY_PK, VOC_ENTITY_PK)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
DEBUG: org.springframework.webflow.execution.AnnotatedAction - Clearing action execution attributes map['method' -> 'manageDatiPersonali_Update']
DEBUG: org.springframework.webflow.execution.ActionExecutor - Finished executing com.sogeit.fids.webfids.actions.DatiPersonaliActions@4a7b483d; result = error
DEBUG: org.springframework.webflow.execution.AnnotatedAction - Clearing action execution attributes map[[empty]]
DEBUG: org.springframework.webflow.execution.ActionExecutor - Finished executing [EvaluateAction@7fb518fb expression = datiPersonaliActions.manageDatiPersonali_Update, resultExpression = [null]]; result = error
DEBUG: org.springframework.webflow.engine.ViewState - Rendering + [JSFView = '/WEB-INF/flows/shome/userprofile/account/manage-datipersonali.xhtml']
DEBUG: org.springframework.webflow.engine.ViewState - Flash scope = map['flowRenderResponse' -> true]
DEBUG: org.springframework.webflow.engine.ViewState - Messages = [DefaultMessageContext@94e13d4 sourceMessages = map[[null] -> list[[Message@64f7c811 source = [null], severity = ERROR, text = 'Errore in fase di aggiornamento: Caught MySQLIntegrityConstraintViolationException for insert into entities_anag_base(COMPANY_NAME, CREATED_BY, CREATION_DATE, ENTITY_AB_PK, FIRST_NAME, LAST_NAME, LAST_UPDATE, MODIFIED_BY, VOC_ENTITY_CATEGORY_PK, VOC_ENTITY_PK)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)']]]]


Guardando bene però cosa mette dentro l'oggetto anagPfToUpdate (che contiene l'anagrafica persone fisiche compilata dall'utente) ci stà questo:

anagPfToUpdate punta a: AnagPf [entityAnagPfPk=0, entityAbPk=0, birthDate=Tue Mar 10 00:00:00 CET 1981, birthPlace=Roma, birthPlaceCode=RM, birthCountryCode2=it, sex=m, vatNumber=4343, creationDate=null, lastUpdate=null, createdBy=0, modifiedBy=0] Luogo di nascita: Roma

E noto delle cose strane:

entityAnagPfPk è la foreign key che dovrebbe legarlo ad un record della tabella AnagBase (quindi in teoria dovrebbe essere la primary key dell'oggetto anagBaseToUpdate...ma NON è QUELLO !!!) ed alcuni campi sono settati a null...

E' possibile che dipenda da ciò il fatto che mi và in errore, si schianta e non me lo inserisce nel DB?

Please, help me...

Grazie mille
Andrea

[Gimli[2BV!2B]]

Penserei che insertAnagPf inserisce i dati in entrambe le tabelle stabilendo il legame della chiave, quindi passandogli un AnagBase già presente insieme ad un AnagPf nuovo fallisce l'inserimento perché il dato base è doppio.
Per controllare questa ipotesi potresti provare ad invocarlo con dati non presenti.

Esiste fidsAnagBaseManager.updateAnagPf ? In caso di risposta affermativa ti consiglierei di provare ad usarlo direttamente, al posto delle updateAnagBase ed insertAnagPf che hai riportato.

Altra idea: si comporta diversamente passando al metodo l'anagrafica base aggiornata?

// Aggiorna l'anagrafica persone fisiche nel database:
			AnagPf updatedAnagPf = fidsAnagBaseManager.insertAnagPf(updatedAnagBase, anagPfToUpdate);
			boolean executedUpdateAnagPf = updatedAnagPf != null;

[e-commerce84]

Originariamente inviato da Gimli[2BV!2B]

Penserei che insertAnagPf inserisce i dati in entrambe le tabelle stabilendo il legame della chiave, quindi passandogli un AnagBase già presente insieme ad un AnagPf nuovo fallisce l'inserimento perché il dato base è doppio.
Per controllare questa ipotesi potresti provare ad invocarlo con dati non presenti.

Esiste fidsAnagBaseManager.updateAnagPf ? In caso di risposta affermativa ti consiglierei di provare ad usarlo direttamente, al posto delle updateAnagBase ed insertAnagPf che hai riportato.

Altra idea: si comporta diversamente passando al metodo l'anagrafica base aggiornata?

// Aggiorna l'anagrafica persone fisiche nel database:
			AnagPf updatedAnagPf = fidsAnagBaseManager.insertAnagPf(updatedAnagBase, anagPfToUpdate);
			boolean executedUpdateAnagPf = updatedAnagPf != null;

Intanto grazie mille per la risposta.

Come tu ipotizzi esiste il metodo fidsAnagBaseManager.updateAnagPf()

Ho provato ad usare anche quello facendo così:
[code]
// Aggiorna l'anagrafica persone fisiche nel database:
AnagPf updatedAnagPf = fidsAnagBaseManager.updateAnagPf(anagBaseToUpdate, anagPfToUpdate);
boolean executedUpdateAnagPf = updatedAnagPf != null;
[/b]

Gli passo l'oggetto anagBaseToUpdate (l'anagrafica di base da aggiornare), anagPfToUpdate (l'anagrafica persone fisiche da aggiornare)

Anche io inizialmente avevo pensato che questa fosse la soluzione giusta perchè credo che in teoria questo metodo debba fare la seguente cosa:

1) Prende l'anagrafica di base e aggiorna il record già presente nel db nella tabella entities_anag_base

2) Crea un nuovo record nella tabella entities_anag_pf (tabella delle anagrafiche persone fisiche), ci inserisce dentro i dati presenti nell'oggetto anagPfToUpdate (tipo il luogo di nascita, data di nascita, sesso dell'utente) e poi mette nel campo ENTITY_AB_PK di tale tabella (sarebbe la foreign key che lega un record di entities_anag_pf con la primary key di un altro record già presente in entities_anag_base) il valore del campo entityAbPk dell'oggetto anagBaseToUpdate....

Credo che in linea puramente teorica dovrebbe funzionare così...ma se faccio questa cosa si schianta dando il seguente errore:


INFO : com.sogeit.fids.webfids.actions.DatiPersonaliActions - Update: luogo di nascita: Roma M Tue Mar 10 00:00:00 CET 1981
anagPfToUpdate punta a: AnagPf [entityAnagPfPk=0, entityAbPk=0, birthDate=Tue Mar 10 00:00:00 CET 1981, birthPlace=Roma, birthPlaceCode=RM, birthCountryCode2=it, sex=M, vatNumber=123, creationDate=null, lastUpdate=null, createdBy=0, modifiedBy=0] Luogo di nascita: Roma
Aggiorna anagrafica di base: true
ERROR: com.sogeit.fids.webfids.actions.DatiPersonaliActions - java.lang.NullPointerException


In pratica mi sembra che il metodo fidsAnagBaseManager.updateAnagPf() non si comporti in questo modo...e ciò è un po' strano perchè se così fosse di fatto se io ho solo un'anagrafica di base nel db ma non ho un'anagrafica persone fisiche non ho modo di crearne una nuova ed inserirla...

In pratica mi pare che in questo caso il metodo fidsAnagBaseManager.updateAnagPf() mi ritorna un oggetto NULL anzichè un oggetto di tipo AnagPf (almeno così ho capito)...

Se così fosse...possibile che ci sia qualcosa di errato nel metodo di business?

Ti allego il codice di tale metodo di business...se hai un po' di tempo gli potresti dare un'occhiata così da confermare o smentire questa ipotesi? (purtroppo non mi occupo io di questa parte e non ci stò capendo un gran chè...se riesci quantomeno a confermare o smentire la mia ipotesi almeno avrei qualcosa di concreto da dire al boss e forse eviterei di essere bevuto...forse...)

@Override
	@Transactional
	public AnagPf updateAnagPf(AnagBase anagBase, AnagPf anagPf) {
		
		DaoRepository<AnagBase,JdbcEntitiesAnagBase> anagBaseRepository =
				daoServiceFactory.getAnagBaseRepository("jdbcAnagBaseRepository"); 
		
		DaoRepository<AnagPf,JdbcEntitiesAnagPf> anagPfRepository =
				daoServiceFactory.getAnagPfRepository("jdbcAnagPfRepository");
		
		
		JdbcEntitiesAnagBase jdbcEntitiesAnagBase = new JdbcEntitiesAnagBase();
		BeanPropertyUtils.copyProperties(anagBase, jdbcEntitiesAnagBase);
		jdbcEntitiesAnagBase.setVocEntityCategoryPk((anagBase.getVocEntityCategoryPk() == 0) ? null : anagBase.getVocEntityCategoryPk());
		AnagBase updateAnagBase = anagBaseRepository.prepareUpdate(jdbcEntitiesAnagBase).update();
		
		
		anagPf.setBirthDate(new java.sql.Date(anagPf.getBirthDate().getTime()));
		anagPf.setCreationDate(new Timestamp(anagPf.getCreationDate().getTime()));
		anagPf.setLastUpdate(new Timestamp(anagPf.getLastUpdate().getTime()));
		
    	JdbcEntitiesAnagPf jdbcEntitiesAnagPf = new JdbcEntitiesAnagPf();
        BeanPropertyUtils.copyProperties(anagPf, jdbcEntitiesAnagPf);
        jdbcEntitiesAnagPf.setEntityAbPk(updateAnagBase.getEntityAbPk());
		
		
		AnagPf updateAnagPf = anagPfRepository.prepareUpdate(jdbcEntitiesAnagPf).update();
		
		
		return updateAnagPf;
	}

Riesci a capire cosa c'è che non và e salvare la vita ad un povero programmatore junior?

Grazie mille
Andrea

[e-commerce84]

Comunque ho provato anche a fare come dicevi te passandogli l'anagrafica base aggiornata

AnagPf updatedAnagPf = fidsAnagBaseManager.insertAnagPf(updatedAnagBase, anagPfToUpdate);
			boolean executedUpdateAnagPf = updatedAnagPf != null;

...tira fuori il seguente errore:


Aggiorna anagrafica di base: true
ERROR: com.sogeit.fids.webfids.actions.DatiPersonaliActions - com.mysema.query.QueryException: Caught MySQLIntegrityConstraintViolationException for insert into entities_anag_base(COMPANY_NAME, CREATED_BY, CREATION_DATE, ENTITY_AB_PK, FIRST_NAME, LAST_NAME, LAST_UPDATE, MODIFIED_BY, VOC_ENTITY_CATEGORY_PK, VOC_ENTITY_PK)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
DEBUG: org.springframework.webflow.execution.AnnotatedAction - Clearing action execution attributes map['method' -> 'manageDatiPersonali_Update']
DEBUG: org.springframework.webflow.execution.ActionExecutor - Finished executing com.sogeit.fids.webfids.actions.DatiPersonaliActions@2594aeed; result = error
DEBUG: org.springframework.webflow.execution.AnnotatedAction - Clearing action execution attributes map[[empty]]
DEBUG: org.springframework.webflow.execution.ActionExecutor - Finished executing [EvaluateAction@f3419f7 expression = datiPersonaliActions.manageDatiPersonali_Update, resultExpression = [null]]; result = error
DEBUG: org.springframework.webflow.engine.ViewState - Rendering + [JSFView = '/WEB-INF/flows/shome/userprofile/account/manage-datipersonali.xhtml']
DEBUG: org.springframework.webflow.engine.ViewState - Flash scope = map['flowRenderResponse' -> true]
DEBUG: org.springframework.webflow.engine.ViewState - Messages = [DefaultMessageContext@100917f0 sourceMessages = map[[null] -> list[[Message@450295c9 source = [null], severity = ERROR, text = 'Errore in fase di aggiornamento: Caught MySQLIntegrityConstraintViolationException for insert into entities_anag_base(COMPANY_NAME, CREATED_BY, CREATION_DATE, ENTITY_AB_PK, FIRST_NAME, LAST_NAME, LAST_UPDATE, MODIFIED_BY, VOC_ENTITY_CATEGORY_PK, VOC_ENTITY_PK)
values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)']]]]

Tnx
Andrea