무아쪽팔리면 질문하지 맙시다. 소중한 답변 댓글을 삭제하는건 부끄러운 일 입니다
아래와 같이 에러 메시지가 나오면서 서버로 데이터가 올라가지 않습니다.
처음에는 잘 올라가다가 나중에 저러고 있는데
쿼리를 날리는 프로그램을 재시작 하면 또 잘 올라가고 일정 시간(횟수)가 지나면 다시 재발합니다.
======= 에러 메세지 ==================
SQL Server에 연결을 설정하는 중에 네트워크 관련 또는 인스턴스 관련 오류가 발생했습니다.
서버를 찾을 수 없거나 액세스할 수 없습니다.
인스턴스 이름이 올바르고 SQL Server가 원격 연결을 허용하도록 구성되어 있는지 확인하십시오.
(provider: TCP Provider, error: 0 - 큐 공간 또는 버퍼가 부족하여 소켓에서 해당 작업을 진행하지 못했습니다.)
=====================================
구글링을 해봐도 원인을 모르겠네요. SQL쪽으로 커넥션을 오래열고 있어서 그렇다는 글도 있던데
아래 코드처럼 쿼리를 날릴 때 마다 함수를 호출하여 켜넥션 하고 쿼리 날리고 연결을 끊어주고 있습니다.
무슨 문제가 있을까요?
public bool WriteDB(string query, bool bReadUncommitted, out string errorMsg)
{
bool ret = false;
errorMsg = "";
SqlConnection connection = null;
string connectString = getConnectionString();
using (connection = new SqlConnection(connectString))
{
try
{
connection.Open();
SqlTransaction sqlTran;
if (bReadUncommitted)
sqlTran = connection.BeginTransaction(IsolationLevel.ReadUncommitted);
else
sqlTran = connection.BeginTransaction();
SqlCommand command = connection.CreateCommand();
command.Transaction = sqlTran;
command.CommandText = query;
command.ExecuteNonQuery();
try
{
sqlTran.Commit();
ret = true;
}
catch (Exception)
{
try
{
sqlTran.Rollback();
}
catch (Exception ex)
{
errorMsg = ex.Message;
}
}
}
catch (Exception ex)
{
errorMsg = ex.Message;
}
finally
{
connection.Close();
}
}
return ret;
}
connection = new SqlConnection(connectString)
로 만든 객체가 가비지 컬렉터에의해서 해제가 안되는 것일수도 있어보입니다.
finally
{
connection.Close();
connection = null; <- 이거 추가해서 명시적으로 참조 해제 처리해주는건 어떨까요?
}
되면 좋고 안되면 말죠 ㅠㅠ
이외에도 어딘가new로 만든것이 가비지컬렉터에 의해 해제되지 않는 것이 있는지
한땀한땀 살펴보는수밖에 없겠네요...
SqlTransaction sqlTran;
SqlCommand command;
라던가..
MS꺼니깐.. 코파일럿한테 물어봤습니다.
이 코드에서 몇 가지 문제점을 발견했습니다. 아래에서 각 문제를 설명하고 수정 방법을 제시하겠습니다:
- 리소스 누수 (Resource Leak):
SqlConnection과 SqlTransaction은 using 블록 내에서 생성되었지만, connection.Close()가 호출되기 전에 메모리에서 해제되지 않습니다.
이로 인해 리소스 누수가 발생할 수 있습니다.
해결 방법: using 블록 내에서 connection과 sqlTran을 생성하고, connection.Close()를 호출하여 리소스를 명시적으로 해제하세요.
- 트랜잭션 처리 문제
트랜잭션 처리 부분에서 중첩된 try-catch 블록이 있습니다.
sqlTran.Commit()이 성공하면 ret이 true로 설정되지만, 만약 Commit()이 실패하면 Rollback()을 시도합니다.
하지만 Rollback()도 실패할 수 있으며, 이 경우 errorMsg에 예외 메시지를 설정하고 ret은 여전히 false로 유지됩니다.
해결 방법: Rollback() 시에도 ret을 false로 설정하고, errorMsg를 설정하세요.
public bool WriteDB(string query, bool bReadUncommitted, out string errorMsg)
{
bool ret = false;
errorMsg = "";
string connectString = getConnectionString();
using (SqlConnection connection = new SqlConnection(connectString))
{
try
{
connection.Open();
SqlTransaction sqlTran;
if (bReadUncommitted)
sqlTran = connection.BeginTransaction(IsolationLevel.ReadUncommitted);
else
sqlTran = connection.BeginTransaction();
SqlCommand command = connection.CreateCommand();
command.Transaction = sqlTran;
command.CommandText = query;
try
{
command.ExecuteNonQuery();
sqlTran.Commit();
ret = true;
}
catch (Exception ex)
{
sqlTran.Rollback();
errorMsg = ex.Message;
}
}
catch (Exception ex)
{
errorMsg = ex.Message;
}
}
return ret;
}
이 수정된 코드는 리소스 누수를 방지하고 트랜잭션 처리를 개선하며, 쿼리 실행 결과를 적절하게 처리합니다
public bool WriteDB(string query, bool bReadUncommitted, out string errorMsg)
{
bool ret = false;
errorMsg = "";
SqlConnection connection = null;
string connectString = getConnectionString();
using (connection = new SqlConnection(connectString))
{
try
{
connection.Open();
using (SqlTransaction sqlTran = bReadUncommitted ? connection.BeginTransaction(IsolationLevel.ReadUncommitted) : connection.BeginTransaction())
{
using (SqlCommand command = connection.CreateCommand())
{
command.Transaction = sqlTran;
command.CommandText = query;
command.ExecuteNonQuery();
try
{
sqlTran.Commit();
ret = true;
}
catch (Exception)
{
try
{
sqlTran.Rollback();
}
catch (Exception ex)
{
errorMsg = ex.Message;
}
}
}
}
}
catch (Exception ex)
{
errorMsg = ex.Message;
}
finally
{
connection.Close();
}
}
return ret;
}
using (SqlTransaction sqlTran = bReadUncommitted ? connection.BeginTransaction(
이 아직 존재하지 않는 (이후에 using 으로 connection 생성) 문제가 있네요 ^^