Привет, я пишу Java-приложение, которое должно создать постоянное соединение с базой данных MySQL.У меня нет доступа к серверу базы данных, поэтому я ничего не могу изменить на сервере базы данных, чтобы он не закрывал соединение.
Я получаю следующую ошибку:
Exception in thread "main" com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure
The last packet successfully received from the server was 368,140 milliseconds ago. The last packet sent successfully to the server was 366,869 milliseconds ago.
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(Unknown Source)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(Unknown Source)
at java.lang.reflect.Constructor.newInstance(Unknown Source)
at com.mysql.jdbc.Util.handleNewInstance(Util.java:409)
at com.mysql.jdbc.SQLError.createCommunicationsException(SQLError.java:1118)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:3055)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2941)
at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:3489)
at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:1959)
at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2113)
at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2568)
at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:2113)
at com.mysql.jdbc.PreparedStatement.executeQuery(PreparedStatement.java:2275)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:101)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveUpdate(SearchAndUpdate.java:110)
at SearchAndUpdate.recursiveTraversal(SearchAndUpdate.java:55)
at SearchAndUpdate.main(SearchAndUpdate.java:40)
Caused by: java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at com.mysql.jdbc.util.ReadAheadInputStream.fill(ReadAheadInputStream.java:114)
at com.mysql.jdbc.util.ReadAheadInputStream.readFromUnderlyingStreamIfNecessary(ReadAheadInputStream.java:161)
at com.mysql.jdbc.util.ReadAheadInputStream.read(ReadAheadInputStream.java:189)
at com.mysql.jdbc.MysqlIO.readFully(MysqlIO.java:2499)
at com.mysql.jdbc.MysqlIO.reuseAndReadPacket(MysqlIO.java:2952)
... 17 more
Я предполагаю, что это сообщение говорит мне, что соединение закрывается автоматически.Я не уверен, что создать постоянное соединение ... Я был бы очень признателен, если бы кто-нибудь дал мне несколько инструкций в коде Java.Заранее большое спасибо.
Ниже приведен мой код, который создает соединение:
import java.sql.*;
public class Connect
{
public static void main (String[] args)
{
Connection conn = null;
try
{
String userName = "sdfasdfsf";
String password = "asdfasdfsd";
String url = "jdbc:mysql://nameOfcomputer:3306/databasename";
Class.forName ("com.mysql.jdbc.Driver").newInstance();
conn = DriverManager.getConnection (url, userName, password);
System.out.println ("Database connection established");
}
catch (Exception e)
{
System.err.println ("Cannot connect to database server");
System.out.println(e.getMessage());
}
}
}
Я только что нашел следующий пример в сети:
http://www.java2s.com/Tutorial/Java/0340__Database/KeeptheConnectionAliveforMySQL.htm
будет ли это примером постоянного соединения?
хорошо, мой код получает соединение, используя тот же код, который я опубликовал, и работает более 4 часов, обновляя таблицу в mysql.приложение в основном выполняет рекурсивный поиск в каталоге, находя все файлы и получая информацию о файле, а затем вводит информацию в базу данных.Каталог поиска содержит более 100 000 файлов.Соединение иногда закрывается, потому что, хотя иногда программе требуется некоторое время для рекурсивного поиска файла, мой код следующий:
public class Search{
public static void main(String[] args) throws SQLException
{
File fileObject = new File("scanLocation");
Connection conn = getConnection();
update(fileObject, conn);
conn.close();
}
public static void update(File fileObject, Connection conn)throws SQLException
{
if (fileObject.isDirectory())
{
File allFiles[] = fileObject.listFiles();
if (allFiles != null)
{
for (File aFile : allFiles)
{
if (aFile.isFile())
{
String filename=aFile.aFile.getName();
String query = "INSERT INTO table("
+ "File_Name" +")"
+ " Values (?)";
try
{ PreparedStatement psmt=conn.prepareStatement(query);
psmt.setString(1, fileName);
psmt.executeUpdate();
}
catch (SQLException e)
{
System.out.println("SQLExceptoin - " + e.getMessage());
System.out.println("SQLState: " + e.getSQLState());
System.out.println("VendorError: " + e.getErrorCode());
e.printStackTrace();
}
}
else
{
recursiveUpdate(aFile, conn);
}
}
}
}
}
public static Connection getConnection()
{
String DATABASE_USER = "user";
String DATABASE_PASSWORD = "password";
String MYSQL_AUTO_RECONNECT = "autoReconnect";
String MYSQL_MAX_RECONNECTS = "maxReconnects";
Connection conn = null;
try
{
String userName = "username";
String password = "password";
String url = "jdbc:mysql://compName:3306/database";
Class.forName("com.mysql.jdbc.Driver").newInstance();
conn = DriverManager.getConnection(url, userName, password);
java.util.Properties connProperties = new java.util.Properties();
connProperties.put(DATABASE_USER, userName);
connProperties.put(DATABASE_PASSWORD, password);
connProperties.put(MYSQL_AUTO_RECONNECT, "true");
connProperties.put(MYSQL_MAX_RECONNECTS, "4");
return DriverManager.getConnection(url, connProperties);
}
catch (Exception e)
{
System.err.println("Cannot connect to database server");
System.out.println(e.getMessage());
e.printStackTrace();
}
return conn;
}
}
Программа иногда завершается, а иногда принудительно закрывает соединение сервер базы данных?Поскольку у меня нет доступа к серверу базы данных, что мне делать, чтобы сервер баз данных не закрывал соединение?
Большое спасибо