ConnectionFactory:
[code]package br.com.conexaodb2.connection;
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
-
@author
*/
public class ConnectionFactory {
// private
private static Connection conectar() {
try {
Class.forName("com.ibm.db2.jcc.DB2Driver");
String url = "jdbc:db2://####";
return DriverManager.getConnection(url, "##", "###");
} catch (SQLException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
return null;
} catch (ClassNotFoundException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
return null;
}
}
public static Connection getConnection() {
Connection conn = null;
try {
if (conn == null || conn.isClosed()) {
conn = conectar();
}
} catch (SQLException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
}
return conn;
}
public static void closeConnection(Connection conn, PreparedStatement ps) {
if (conn != null) {
try {
ps.close();
conn.close();
} catch (SQLException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
public static void closeConnection(Connection conn, PreparedStatement ps, ResultSet rs) {
if (conn != null) {
try {
rs.close();
closeConnection(conn, ps);
} catch (SQLException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
public static void closeConnection2(Connection conn, CallableStatement cs) {
if (conn != null) {
try {
cs.close();
conn.close();
} catch (SQLException ex) {
Logger.getLogger(ConnectionFactory.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
}[/code]
Action:
[code] if (tipoConsulta.equals(“1”)) {
String fonte = request.getParameter(“fonte”).trim();
String checkteste[] = request.getParameterValues(“checkteste”);
String nomeUsuario = request.getParameter(“nomeUsuario”);
String idUsuario = request.getParameter(“idUsuario”);
int contador = 0;
Integer IidUsuario = Integer.parseInt(idUsuario);
String IdDocContabil;
String[] x = checkteste;
System.out.println("UPDATE----------------------------------------------");
for (int i = 0; i < x.length; i++) {
IdDocContabil = x[i];
contador = contador + 1;
if (salvar(IdDocContabil, fonte, 1, IidUsuario, nomeUsuario)) {
request.setAttribute("alertUpFr", "Atualizado com Sucesso!!!");
} else {
request.setAttribute("alertUpFr", "Erro ao Atualizar Fonte!!!");
}
}
String dtFinal = (String) request.getSession().getAttribute("dtFinal");
String dtInicial = (String) request.getSession().getAttribute("dtInicial");
String idDetalhe = (String) request.getSession().getAttribute("idDetalhe");
String idTipoDoc = (String) request.getSession().getAttribute("idTipoDoc");
String executivo = request.getParameter("executivo").trim();
String fmas = request.getParameter("FMAS").trim();
String saude = request.getParameter("saude").trim();
String educacao = request.getParameter("educacao").trim();
String fundeb = request.getParameter("FUNDEB").trim();
request.getSession().removeAttribute("lstUFR");
request.getSession().removeAttribute("lstFonte");
request.getSession().removeAttribute("vlNumProc");
request.getSession().removeAttribute("vlNumOrd");
request.getSession().setAttribute("vlNumProc", "");
request.getSession().setAttribute("vlNumOrd", "");
request.getSession().setAttribute("lstUFR", new updateFonteRecursoDAO().getUFRs(idDetalhe,
dtInicial,
dtFinal,
idTipoDoc,
executivo,
fmas,
saude,
educacao,
fundeb));
request.getSession().setAttribute("lstFonte", new updateFonteRecursoDAO().getIdDetalhe(idDetalhe,
dtInicial,
dtFinal));
//System.out.println("quantidade de updates : ");
//System.out.println(contador);
request.setAttribute("msg", "Fonte Atualizada");
request.getRequestDispatcher("mostraResultado.jsp").forward(request, response);
return;
} [/code]
DAO:
...
// ------------------------------------------------------------------------- UPDATE - FONTES
public boolean upIdDetalheUFRs(String IdDocContabil,
String fontel,
int tipoUpdate,
int idUsuario,
String nomeUsuario) {
Connection conn = null;
CallableStatement cs = null;
boolean isOk = false;
conn = ConnectionFactory.getConnection();
if (conn == null) {
return isOk;
}
sql = UFRQuerry.upIdDetalheUFRs(IdDocContabil, fontel, tipoUpdate, idUsuario, nomeUsuario);
try {
conn.setAutoCommit( false );
cs = conn.prepareCall (sql);
cs.execute();
isOk = true;
} catch (SQLException ex) {
Logger.getLogger(updateFonteRecursoDAO.class.getName()).log(Level.SEVERE, null, ex);
} finally {
ConnectionFactory.closeConnection(conn, cs);
}
return isOk;
}
...