Servletter gengrug af Statements

Der er normalt ikke nogen grund til at genbruge Statement, da det ikke koster
noget at oprette et sådant.

Jeg tror grundliggende at jeres problem er at et ResultSet ikke indeholder
resulatet af en query, men kun en pege pind til hvor lang man er kommet med
at hente resultatet. Det er next som faktisk henter data. Man skal derfor
enten køre et result set færdigt eller have 2 connections, 2 statement og
2 results et.

Personligt bruger jeg normalt:
  ResultSet rs = stmt.executeQuery();

Har I overvejer jeres kode i en multithreaded context ?

Okay, det forklarer en del da vi i de tilfælde jeg har testet har begge while efter:

          st.execute(query1);
          ResultSet rs1 = st.getResultSet();
          st.execute(query2);
          ResultSet rs2 = st.getResultSet();

har det nogen betydning om man bruger:

      ResultSet rs = stmt.executeQuery();
      eller
      st1.execute(query1);
      ResultSet rs1 = st1.getResultSet();

Og hvad mener du med det her:
"Har I overvejer jeres kode i en multithreaded context ?"

... og endnu engang tak for de hurtige svar!!!

På forhånd tak
Rasmus

execute() og getResultSet() bruger man normalt med stored procedures som
kan returnere flere result set.

executeQuery bruger man ved normale queries som returnerer et enkelt result set.

Der er ingen funktionel forskel så vidt jeg ved.

Hvis to brugere requester samme servlet samtidigt hvad sker der så med:

public static Statement    st;

?

Er det her SingleThread kommer ind i billedet?

Hvis du implements SingleThreadModel og laver public static Statement    st; om til
public Statement    st (uden static), så begynder det at ligne noget.

Selvom løsningen stadig er en anelse utraditionel.

Har du et andet forslag????? ;-D

Den traditionelle løsning er:
  - connections fra connection pool
  - statements og result set som variable indeni metoderne
hvilket er thread safe uden brug af SingleThreadModel

Du har evt. ikke nogle referencer til steder hvor jeg kan læser mere om det og få eksempler fordi det lyder da som en lidt smartere fremgangsmåde!

Og lav evt. et svar så du kan få point.

Tusind tak for hjælpen.
MVH.
Rasmus

Jeg har faktisk skrevet en lille artikel som beskriver connection pool i Tomcat.

http://www.eksperten.dk/artikler/50

Brug af lokale variabele i metoderne er jo ligeud af landevejen.

Jeg kan evt. lave et komplet eksempel i aften.

svar

Det ville være fantastisk!!! Nu læser jeg lige lidt på artiklen!

Endnu engang tak for svarene!
MVH.
Rasmus

Hej Arne
Nu har jeg læst din artikel, men det muligt at løse Concurrency problemet uden at skulle rette i server.xml filen. Andet end ved at implemente SingleThread!

MVH.
Rasmus

Er det et problem at rette i server.xml ?

Udover min artikel er følgende link også godt:
  http://java.sun.com/developer/Books/javaserverpages/tomcat/Sams-Tomcat-KS_ch09.pdf

Hvis I kan rette i server.xml, så følger I bare vejledningen i min artikel og
ovenstående link. Det er rimeligt veldokumenteret.

Hvis I ikke kan rette i server.xml så laver I jeres egen connection pool.

Eksempel:

import java.io.*;
import java.sql.*;

import javax.servlet.*;
import javax.servlet.http.*;

import org.apache.commons.dbcp.*;
import org.apache.commons.pool.impl.*;

public class PoolServlet extends HttpServlet {
    private GenericObjectPool cp;
    private DriverManagerConnectionFactory dmcf;
    private PoolableConnectionFactory pcf;
    private PoolingDataSource ds;
    public void init() {
        try {
            Class.forName("com.mysql.jdbc.Driver");
            cp = new GenericObjectPool(null);
            dmcf = new DriverManagerConnectionFactory("jdbc:mysql://localhost/Test", "", "");
            pcf = new PoolableConnectionFactory(dmcf, cp, null, null, false, true);
            ds = new PoolingDataSource(cp);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public void doGet(HttpServletRequest request, HttpServletResponse response)
        throws ServletException, IOException {
        try {
            Connection con = ds.getConnection();
            Statement stmt = con.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM T1");
            while (rs.next()) {
                int f1 = rs.getInt(1);
                String f2 = rs.getString(2);
                response.getWriter().println(f1 + " " + f2 + "<BR/>");
            }
            rs.close();
            stmt.close();
            con.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}