Версия для печати темы
Нажмите сюда для просмотра этой темы в оригинальном формате
Форум программистов > Java EE (J2EE) и Spring > Connection with MySQL


Автор: NewProgr 6.9.2006, 04:21
Подскажите, пожалуйста, кому не сложно самый простой способ создания Connection с базой MySql
(чем подробнее, тем лучше) для сервера Tomcat 4.1

пусть:
   база MySQL: javatest
   user : Test
   password : test

Заранее благодарен

Автор: Alexandr87 6.9.2006, 06:47
я предпочитаю использовать источники данных, получаемых по jndi.
http://tomcat.apache.org/tomcat-4.1-doc/jndi-datasource-examples-howto.html

но можно использовать jdbc напрямую
http://www.developer.com/java/data/article.php/3417381

Автор: Gliven 6.9.2006, 20:50
Вот еще способ конекшена через JDBC: 
Код

public java.sql.Connection getConnection() throws SQLException
    {
        String user = null;
        String password = null;
        String url = null;
        String drivers = null;
        boolean useUnicode = true;
        String characterEncoding = null;
        //Описываешь чтение конф. файла

        Properties props = new Properties();
        try
        {
            FileInputStream in = new FileInputStream("config.properties");
            props.load(in);
            in.close();
            drivers = props.getProperty("jdbc.drivers");
            if (drivers != null)
                System.setProperty("jdbc.drivers", drivers);
            url = props.getProperty("jdbc.url");
            user = props.getProperty("jdbc.username");
            password = props.getProperty("jdbc.password");
            //useUnicode = props.getProperty("jdbc.useUnicode");
            characterEncoding = props.getProperty("jsbc.characterEncoding");
        }
        catch (IOException e)
        {
            System.out.println("Using default values");
        }
        user = (user==null)?"root":user;
        password = (password==null)?"root":password;
        url = (url==null)?"jdbc:mysql://OPSUR1:3306/testrun":url;
        drivers = (drivers==null)?"com.mysql.jdbc.Driver":drivers;
        characterEncoding = (characterEncoding==null)?"KOI8_R":characterEncoding;

        try
        {
            Class.forName(drivers);
        }
        catch(Exception e)
        {
            System.out.println("Driver not found");
        }
        return DriverManager.getConnection(url, user, password);
    }

    public void addTopic(String topic)
    {
        try
        {
//            Statement statement = getConnection().createStatement();
            String str;
//            str = "insert into topic values (null,'"+topic+"')";
//            statement.executeUpdate(str);
//      str = "insert into topic (topic) values ('"+topic+"')";
            str = "insert into topic (topic) values (?)";
            PreparedStatement statement = getConnection().prepareStatement(str);
            statement.setString(1,topic);
            statement.executeUpdate();
            
            
//            statement.prepareStatement(str);
//            statement.setString(1, topic);
//            statement.executeUpdate();
        }
        catch (Exception e)
        {
            System.out.println("" + e);
        }
    }

    public List<TopicBrief> getTopics()
    {
        List<TopicBrief> result = new ArrayList<TopicBrief>();
        try
        {
            Statement statement = getConnection().createStatement();
            String str = "select * from topic";
            ResultSet rs = statement.executeQuery(str);
            while (rs.next())
            {
                TopicBrief topic = new TopicBrief();
                topic.setId(rs.getInt(1));
                topic.setName(rs.getString(2));
                result.add(topic);
            }
            rs.close();
            statement.close();
        }
        catch (Exception e)
        {
            System.out.println("" + e);
        }
        return result;
    }


Или через hibernate:
Код

import org.hibernate.*;
import org.hibernate.cfg.AnnotationConfiguration;
import ru.customs.novoros.common.exceptions.AllException;

public class HibernateUtil {
    private static SessionFactory sessionFactory;

    public static final ThreadLocal<Session> session = new ThreadLocal<Session>();

    private HibernateUtil() {
    }

    public static Session currentSession() throws AllException {
        Session s = session.get();
        if (null == s) {
            s = getSessionFactory().openSession();
            session.set(s);
        }
        return s;
    }

    public static void closeSession() throws AllException {
        final Session s = session.get();
        session.set(null);
        if (null != s) {
            try {
                s.close();
            } catch (HibernateException e) {
                throw new AllException("Cannot close Hibernate session", e);
            }
        }
    }

    private static SessionFactory getSessionFactory() throws AllException {
        if (null == sessionFactory) {
            synchronized (HibernateUtil.class) {
                if (null == sessionFactory) {
                    try {
                        sessionFactory = new AnnotationConfiguration()
                                .configure().buildSessionFactory();
                    } catch (HibernateException e) {
                        throw new AllException(
                                "Cannot initialize Hibernate subsystem", e);
                    }
                }
            }
        }
        return sessionFactory;
    }

}


Добавлено @ 20:55 
Да, забыл сказать, прописи пароля, базы описываешь в hibernate.cfg.xml:
Код

<!DOCTYPE hibernate-configuration PUBLIC
        "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

<hibernate-configuration>
    <session-factory name="defaultFactory">
        <property name="hibernate.current_session_context_class">thread</property>
        <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
        <property name="hibernate.connection.url">jdbc:mysql://localhost:3306/tara</property>
        <property name="hibernate.connection.username">root</property>
        <property name="hibernate.connection.password">root</property>
        <property name="hibernate.connection.useUnicode">true</property>
        <property name="hibernate.connection.charSet">koi8-r</property>        
        <property name="hibernate.connection.characterEncoding">koi8-r</property>
        <property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
        
        <property name="hibernate.hbm2ddl.auto">update</property>

        <property name="hibernate.cache.provider_class">org.hibernate.cache.NoCacheProvider</property>

        <mapping class="***"/>
        

    </session-factory>
</hibernate-configuration>

Данный xml описан под работу с MySQL.

Автор: tux 7.9.2006, 04:34
Gliven, настройки соединения с MySQL в Tomcat ведь попросили, а не как настроить Hibernate.

Автор: Bulat 7.9.2006, 07:45
Цитата(tux @  7.9.2006,  04:34 Найти цитируемый пост)
Gliven, настройки соединения с MySQL в Tomcat ведь попросили, а не как настроить Hibernate.

Ну томкат, не томкат, что-то не видел особых различий и при использовании Hibernate или JDBC, что в томкате или вне его. А так вот JDBC, чуть попроще чем Hibernate, более стандартный.

Вот тебе класс с коннектом и дестроем smile 
Код

public class Connect {

    public Connection init() {
        String databaseurl = "jdbc:mysql://<хост>:<порт>/javatest?lc_ctype=KOI8-R",
                      user = "Test",
                  password = "test",
                driverName = "com.mysql.jdbc.Driver";
        Connection con = null;
        try {
            Class.forName(driverName).newInstance();
            con = DriverManager.getConnection(databaseurl, user, password);
        } catch (InstantiationException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        } catch (IllegalAccessException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        } catch (ClassNotFoundException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        } catch (SQLException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
        return con;
    }


    public void destroy (Connection con) {
        try {
            con.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

}


P.S. Вроде бы все верно(сократил свой класс, он у меня побольше и помуторнее, оставив только минимум необходимого smile )

Автор: tux 7.9.2006, 08:37
Bulat, одно замечание насчет использования твоего кода в production. Если у тебя этот класс используется в толстом клиенте (например, Swing-приложение), то его применение вполне оправдано. Один пользователь - одно соединение, которое поддерживается в открытом состоянии на все время работы приложения.

Если это веб-приложение, то здесь все несколько сложнее. В принципе можно использовать ту же самую схему - подключается новый пользователь, открывается соединение и использует постоянно на протяжении сеанса. Но веб-приложения традиционно обслуживают большее число пользователей чем разработанные по схеме толстый клиент. Да и в том случае если подразумевается, что со Swing-приложением будет работать очень большое количество пользователей такая схема не применяется. Причина проста: каждое соединение - это область памяти на сервере, может быть и не очень большая, но когда их много, это становится проблемой. Кроме того, поток запросов от пользователей, как правило, не очень интенсивен. Получается, что подавляющую часть времени это огромное число соединений не используется. А это, сам понимаешь, не эффективно. Кроме того, таким образом можно легко превысить максимальное количество соединений, которые СУБД может открыть.

Как же бороться с этой неэффективностью? А проблема решается достаточно просто. Во всех реальных больших веб-системах, работающих с базами данных используются пулы соединений. Создается массив соединений, ограниченный по количеству снизу и сверху (то есть минимальное количество соединений, которые открыты всегда и максимальное, больше которого открыть не разрешается чтобы не превысить ограничения СУБД). При попытке получить пользователем новое соединение менеджер пула соединений сначала смотрит а нет ли среди открытых соединений свободных, которые могут быть использованы. Если есть, то возвращает одно из них. Если нет, то проверяет не превышено ли доступное количество открытых соединений. Если нет, то открывает новое и возвращает клиенту. Если превышено, то запрос на соединение просто блокируется до тех пор пока хотя бы одно из соединений не освободится. При закрытии соединения клиентом соединение не закрывается реально, а помещается в массив свободных соединений.

Что получаем в результате:
  • соединений мало, используются они эффективно, ресурсов на сервере расходуется меньше
  • операции открытия и закрытия соединений в некоторых СУБД ресурсоемки по времени, в результате увеличивается быстродействие
Так что если твой класс используется в production, советовал бы внимательнее присмотреться к пулам соединений. Можно использовать то, что предоставляет Tomcat (посмотри по ссылкам, которые дал Alexandr87). Tomcat в качестве пула соединений использует библиотеку http://jakarta.apache.org/commons/dbcp/. А можно использовать и любую библиотеку помимо Tomcat. Еще бы рекомендовал посмотреть на http://sourceforge.net/projects/c3p0 и http://proxool.sourceforge.net/.

Кстати, Hibernate даже в дефолтной кофигурации все-таки использует пул соединений, правда свой собственный и совсем простенький. И они рекомендуют использовать Hibernate на реальной нагрузке только в комбинации с какой-нибудь серьезной библиотекой, обеспечивающей организацию пула.

Автор: Bulat 7.9.2006, 11:30
Цитата(tux @  7.9.2006,  08:37 Найти цитируемый пост)
Если это веб-приложение, то здесь все несколько сложнее. В принципе можно использовать ту же самую схему - подключается новый пользователь, открывается соединение и использует постоянно на протяжении сеанса.

А зачем только тоскать соединение на протяжении сеанса? Если у меня пользователь пассивно весит, т.е. в браузере открыта страница, так и может висеть весь день а то и больше? Если ему что-то надо приконнектился, вывел необходимые данные на страницу, закрыл коннект.

Автор: tux 7.9.2006, 11:39
Цитата(Bulat @  7.9.2006,  16:30 Найти цитируемый пост)
Если ему что-то надо приконнектился, вывел необходимые данные на страницу, закрыл коннект. 

Тогда длительность подключения может в конечном счете сказать на производительности. Согласен, в MySQL создание соединения проходит достаточно быстро и на приложении с небольшим числом клиентов ощутимой разницы не будет. Но в многих СУБД процесс подключения хорошо заметен даже на глаз. Кроме того, еще одно достоинство пула - можно контролировать количество одновременно открытых соединений в то время как в твоей конструкции при превышении лимита СУБД во время пиковых нагрузок просто будет отказывать в подключении.

Автор: Bulat 7.9.2006, 12:31
Цитата(tux @  7.9.2006,  11:39 Найти цитируемый пост)
Тогда длительность подключения может в конечном счете сказать на производительности. Согласен, в MySQL создание соединения проходит достаточно быстро и на приложении с небольшим числом клиентов ощутимой разницы не будет. Но в многих СУБД процесс подключения хорошо заметен даже на глаз. Кроме того, еще одно достоинство пула - можно контролировать количество одновременно открытых соединений в то время как в твоей конструкции при превышении лимита СУБД во время пиковых нагрузок просто будет отказывать в подключении. 

Это уже другой вопрос, и тут я с тобой полностью согласен smile 
Надо всегда смотреть по обстоятельствам

Автор: NewProgr 8.9.2006, 09:17
Народ, огромное спасибо за участие.
Сделал на JNDI.

А как на JSP странице писать русскими буквами при настройке :
Код

<%@ page contentType="text/html;charset=UTF-8" language="java" %>

т.е. чтобы русский текст в html тегах отображался корректно?

Автор: tux 8.9.2006, 09:53

M
tux		NewProgr, почитай правила форума. Для каждого вопроса - новая тема.

Автор: NewProgr 8.9.2006, 12:24
Виноват, извиняюсь smile 

Powered by Invision Power Board (http://www.invisionboard.com)
© Invision Power Services (http://www.invisionpower.com)