同时开21个进程对SQL进行速度测试

王朝mssql·作者佚名 2006-01-09

宽屏版字体: 小|中|大|超大

主要为了看一下，多个进程多表对SQL进行操作和单进程对单个表进行写数据的效率问题。

3次测试出来的数据如下

主console程序（由此进程创建21个进程）

table1——table20为20个进程对20个表分别写1万条记录

table总为单进程对1个表写20万条记录

所有表中只有1个为name的char字段

数据如下

第一次：

主console程序开始时间：21分25秒

table6开始时间：21分25秒

table5开始时间：21分25秒

主console程序结束时间：21分25秒

table1开始时间：21分25秒

table2开始时间：21分25秒

table总开始时间：21分25秒

table8开始时间：21分25秒

table3开始时间：21分25秒

table4开始时间：21分26秒

table7开始时间：21分26秒

table9开始时间：21分26秒

table10开始时间：21分26秒

table12开始时间：21分26秒

table13开始时间：21分26秒

table11开始时间：21分26秒

table15开始时间：21分26秒

table18开始时间：21分26秒

table17开始时间：21分26秒

table19开始时间：21分27秒

table14开始时间：21分27秒

table20开始时间：21分27秒

table16开始时间：21分27秒

table18结束时间：22分41秒

table19结束时间：22分41秒

table14结束时间：22分41秒

table1结束时间：22分41秒

table3结束时间：22分42秒

table17结束时间：22分42秒

table2结束时间：22分42秒

table9结束时间：22分42秒

table20结束时间：22分42秒

table6结束时间：22分42秒

table13结束时间：22分59秒

table5结束时间：23分0秒

table16结束时间：23分0秒

table8结束时间：23分0秒

table7结束时间：23分0秒

table11结束时间：23分0秒

table10结束时间：23分1秒

table12结束时间：23分1秒

table15结束时间：23分1秒

table4结束时间：23分1秒

table总结束时间：24分41秒

第二次：

主console程序开始时间：27分48秒

table9开始时间：27分48秒

table2开始时间：27分48秒

table3开始时间：27分48秒

主console程序结束时间：27分48秒

table总开始时间：27分48秒

table5开始时间：27分49秒

table1开始时间：27分49秒

table6开始时间：27分49秒

table7开始时间：27分49秒

table8开始时间：27分49秒

table4开始时间：27分49秒

table12开始时间：27分49秒

table10开始时间：27分50秒

table13开始时间：27分50秒

table15开始时间：27分50秒

table16开始时间：27分50秒

table18开始时间：27分50秒

table14开始时间：27分50秒

table19开始时间：27分50秒

table11开始时间：27分50秒

table17开始时间：27分50秒

table20开始时间：27分50秒

table3结束时间：28分52秒

table9结束时间：28分53秒

table5结束时间：29分0秒

table12结束时间：29分2秒

table16结束时间：29分2秒

table19结束时间：29分2秒

table14结束时间：29分3秒

table17结束时间：29分3秒

table13结束时间：29分3秒

table4结束时间：29分3秒

table7结束时间：29分3秒

table2结束时间：29分11秒

table6结束时间：29分15秒

table11结束时间：29分15秒

table18结束时间：29分16秒

table8结束时间：29分16秒

table20结束时间：29分16秒

table10结束时间：29分17秒

table1结束时间：29分17秒

table15结束时间：29分17秒

table总结束时间：31分2秒

第三次：

主console程序开始时间：32分17秒

table12开始时间：32分17秒

主console程序结束时间：32分17秒

table17开始时间：32分17秒

table2开始时间：32分18秒

table3开始时间：32分18秒

table1开始时间：32分18秒

table总开始时间：32分18秒

table7开始时间：32分18秒

table6开始时间：32分18秒

table5开始时间：32分18秒

table4开始时间：32分18秒

table10开始时间：32分18秒

table8开始时间：32分18秒

table9开始时间：32分18秒

table11开始时间：32分18秒

table13开始时间：32分18秒

table16开始时间：32分19秒

table20开始时间：32分19秒

table15开始时间：32分19秒

table14开始时间：32分19秒

table18开始时间：32分19秒

table19开始时间：32分19秒

table17结束时间：33分19秒

table2结束时间：33分24秒

table1结束时间：33分28秒

table10结束时间：33分29秒

table20结束时间：33分30秒

table9结束时间：33分30秒

table6结束时间：33分31秒

table14结束时间：33分31秒

table11结束时间：33分31秒

table18结束时间：33分31秒

table13结束时间：33分31秒

table12结束时间：33分36秒

table3结束时间：33分41秒

table5结束时间：33分43秒

table16结束时间：33分43秒

table7结束时间：33分43秒

table4结束时间：33分43秒

table19结束时间：33分44秒

table15结束时间：33分44秒

table8结束时间：33分44秒

table总结束时间：35分40秒

从数据可以看出来，21个进程同时写40万条记录大约需要3分钟多点的时间。

20个进程同时写的时间只比1个进程写快2分钟左右，当然这样测试是很不准确的，因为21个进程同时开，那单独写20万数据的进程所分配到的CPU时间片是很少的。

机器为512M，2.4G

也可以测试其它方面的，只要把程序稍微改动一下就可以。

程序B主控，程序A是用来开20个进程的，程序C是用来开1个进程的。

代码我都贴在下面

// DataAccess.h: interface for the CDataAccess class.

//////////////////////////////////////////////////////////////////////

#if !defined(AFX_DATAACCESS_H__BE165B0F_3E92_44BC_9C3B_6F4CC36AD153__INCLUDED_)

#define AFX_DATAACCESS_H__BE165B0F_3E92_44BC_9C3B_6F4CC36AD153__INCLUDED_

#if _MSC_VER > 1000

#pragma once

#endif // _MSC_VER > 1000

#include <assert.h>

#include <iostream>

#include <string>

using namespace std;

#define READ_ONLY 1

#define WRITE_ONLY 2

#define READ_WRITE 3

template<typename Container, typename ValueType, int nPropType>

class CProperty

{

public:

CProperty()

{

m_cObject = NULL;

Set = NULL;

Get = NULL;

}

//设置属性所在的对象指针

void setContainer(Container* cObject)

{

m_cObject = cObject;

}

//设置set指针,用来修改属性用

void setter(void (Container::*pSet)(ValueType value))

{

if((nPropType == WRITE_ONLY) || (nPropType == READ_WRITE))

Set = pSet;

else

Set = NULL;

}

//设置get指针,用来读取属性用

void getter(ValueType (Container::*pGet)())

{

if((nPropType == READ_ONLY) || (nPropType == READ_WRITE))

Get = pGet;

else

Get = NULL;

}

//重载=操作符,用于实现这样的操作 CAdoConnection.Connected = TRUE;

//注意CAdoConnection.Connected其实是一个CProperty的对象

//属性的实现关键在于重载=操作符和隐式转换操作符

//重载后调用CProperty的拥有者的get、set函数来达到目的

ValueType operator =(const ValueType& value)

{

assert(m_cObject != NULL);

assert(Set != NULL);

(m_cObject->*Set)(value);

return value;

}

//重载隐式转换操作符

operator ValueType()

{

assert(m_cObject != NULL);

assert(Get != NULL);

return (m_cObject->*Get)();

}

private:

Container* m_cObject; //属性的拥有者

void (Container::*Set)(ValueType value); //set函数指针

ValueType (Container::*Get)(); //get函数指针

};

class CAdoConnection

{

public:

CAdoConnection();

~CAdoConnection();

//隐式的转换操作,不推荐使用,只是暂时类没有封装好,给客户一个方便

//使用时请确保指针在类的生命期内使用

operator _ConnectionPtr();

public:

CProperty<CAdoConnection, BOOL, READ_WRITE> Connected;

string ConnectingString;

string UserName, PassWord;

private:

void SetConnected(BOOL ConnectFlag);

BOOL GetConnected();

private:

_ConnectionPtr m_ptrConn;

friend class CAdoCommand;

friend class CAdoQuery;

};

class CAdoCommand

{

public:

CAdoCommand();

~CAdoCommand();

void Execute();

operator _CommandPtr();

public:

CommandTypeEnum CommandType;

string CommandText;

CAdoConnection * m_AdoConnection;

private:

_CommandPtr m_ptrComm;

};

class CAdoQuery

{

public:

CAdoQuery();

~CAdoQuery();

void Open();

operator _RecordsetPtr();

public:

string Sql;

CAdoConnection * m_AdoConnection;

private:

_RecordsetPtr m_ptrRec;

};

#endif // !defined(AFX_DATAACCESS_H__BE165B0F_3E92_44BC_9C3B_6F4CC36AD153__INCLUDED_)

// DataAccess.cpp: implementation of the CDataAccess class.

//////////////////////////////////////////////////////////////////////

#include "stdafx.h"

#include "DataAccess.h"

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[]=__FILE__;

#define new DEBUG_NEW

#endif

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

//CAdoConnection

CAdoConnection::CAdoConnection()

{

Connected.setContainer(this);

Connected.setter(&CAdoConnection::SetConnected);

Connected.getter(&CAdoConnection::GetConnected);

// 创建一个连接实例

try {

HRESULT hr = m_ptrConn.CreateInstance(__uuidof(Connection));

if (FAILED(hr)) {

CString errormessage("创建实例失败!");

AfxMessageBox(errormessage);

throw;

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("创建实例失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

// 设定连接等待的最大秒数，默认是15秒

m_ptrConn->ConnectionTimeout=15;

UserName = "";

PassWord = "";

}

CAdoConnection::~CAdoConnection()

{

if (GetConnected())

SetConnected(FALSE);

m_ptrConn=NULL;

}

CAdoConnection::operator _ConnectionPtr()

{

return m_ptrConn;

}

void CAdoConnection::SetConnected(BOOL ConnectFlag)

{

if (TRUE == ConnectFlag) {

try {

// 打开连接

m_ptrConn->Open(ConnectingString.c_str(), UserName.c_str(), PassWord.c_str(), adModeUnknown);

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("连接数据库失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

else {

m_ptrConn->Close();

}

BOOL CAdoConnection::GetConnected()

{

if (m_ptrConn->State == adStateOpen)

return TRUE;

else

return FALSE;

}

//CAdoCommand

CAdoCommand::CAdoCommand()

{

m_AdoConnection = NULL;

CommandText = adCmdText;

// 创建一个命令对象实例

try {

HRESULT hr = m_ptrComm.CreateInstance(__uuidof(Command));

if (FAILED(hr)) {

CString errormessage("创建实例失败!");

AfxMessageBox(errormessage);

throw;

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("创建实例失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

CAdoCommand::~CAdoCommand()

{

m_ptrComm = NULL;

}

void CAdoCommand::Execute()

{

if ((m_AdoConnection == NULL) || (m_AdoConnection->Connected == FALSE))

return;

m_ptrComm->ActiveConnection = m_AdoConnection->m_ptrConn;

m_ptrComm->CommandType = CommandType;

m_ptrComm->CommandText = CommandText.c_str();

try {

m_ptrComm->Execute(NULL,NULL,adCmdUnknown);

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("查询数据库失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

CAdoCommand::operator _CommandPtr()

{

return m_ptrComm;

}

//CAdoQuery

CAdoQuery::CAdoQuery()

{

m_AdoConnection = NULL;

// 创建一个_RecordsetPtr对象实例

try {

HRESULT hr = m_ptrRec.CreateInstance("ADODB.Recordset");

if (FAILED(hr)) {

CString errormessage("创建实例失败!");

AfxMessageBox(errormessage);

throw;

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("创建实例失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

CAdoQuery::~CAdoQuery()

{

m_ptrRec = NULL;

}

void CAdoQuery::Open()

{

if ((m_AdoConnection == NULL) || (m_AdoConnection->Connected == FALSE))

return;

try {

m_ptrRec->Open(Sql.c_str(), (m_AdoConnection->m_ptrConn).GetInterfacePtr(), adOpenDynamic, adLockOptimistic, adCmdText);

}

catch(_com_error & error) {

CString errormessage;

errormessage.Format("查询数据库失败!\r\n错误信息:%s", error.ErrorMessage());

AfxMessageBox(errormessage);

}

CAdoQuery::operator _RecordsetPtr()

{

return m_ptrRec;

}

// a.cpp : 定义控制台应用程序的入口点。

#include "stdafx.h"

#include "a.h"

#include "DataAccess.h"

#include <fstream>

using namespace std;

#ifdef _DEBUG

#define new DEBUG_NEW

#endif

// 唯一的应用程序对象

CWinApp theApp;

using namespace std;

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])

{

int nRetCode = 0;

ofstream file("test.txt",std::ios::app);

CTime ct;

CString text;

ct = CTime::GetCurrentTime();

text.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << argv[1] << "开始时间：" << text << endl;

CoInitialize(NULL);

// 初始化 MFC 并在失败时显示错误

if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))

{

// TODO: 更改错误代码以符合您的需要

_tprintf(_T("致命错误: MFC 初始化失败\n"));

nRetCode = 1;

}

else

{

// TODO: 在此处为应用程序的行为编写代码。

CAdoConnection AdoConnection;

CAdoCommand AdoCommand;

AdoConnection.ConnectingString = "Provider=SQLOLEDB;Network Address=127.0.0.1;Initial Catalog=临时数据库";

AdoConnection.UserName = "sa";

AdoConnection.PassWord = "sa";

if (AdoConnection.Connected == FALSE)

AdoConnection.Connected = TRUE;

AdoCommand.CommandType = adCmdText;

AdoCommand.CommandText = string("INSERT INTO ") + string(argv[1]) + string(" (name) VALUES ('ghb')");

AdoCommand.m_AdoConnection = &AdoConnection;

for (int i = 0; i<10000; i++)

AdoCommand.Execute();

AdoConnection.Connected = FALSE;

}

CoUninitialize();

ct = CTime::GetCurrentTime();

text.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << argv[1] << "结束时间：" << text << endl;

return nRetCode;

}

// b.cpp : 定义控制台应用程序的入口点。

#include "stdafx.h"

#include "b.h"

#include <fstream>

using namespace std;

#ifdef _DEBUG

#define new DEBUG_NEW

#endif

// 唯一的应用程序对象

CWinApp theApp;

using namespace std;

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])

{

int nRetCode = 0;

ofstream file("test.txt",std::ios::app);

CTime ct;

CString temp;

ct = CTime::GetCurrentTime();

temp.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << "主console程序开始时间：" << temp << endl;

// 初始化 MFC 并在失败时显示错误

if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))

{

// TODO: 更改错误代码以符合您的需要

_tprintf(_T("致命错误: MFC 初始化失败\n"));

nRetCode = 1;

}

else

{

// TODO: 在此处为应用程序的行为编写代码。

CString command, TableName;

CString str;

TableName = "table总";

str = CString("E:\\OutPut\\c\\c\\Debug\\c.exe ") + TableName;

STARTUPINFO LargeSi = {0};

LargeSi.cb = sizeof(STARTUPINFO);

PROCESS_INFORMATION LargePf;

::CreateProcess(NULL, str.GetBuffer(), NULL, NULL, FALSE, CREATE_NEW_CONSOLE, NULL, NULL, &LargeSi, &LargePf);

for (int i=1; i<=20; i++)

{

temp.Format("%d", i);

TableName = CString("table") + temp;

str = CString("E:\\OutPut\\a\\a\\Debug\\a.exe ") + TableName;

//AfxMessageBox(str);

STARTUPINFO si = {0};

si.cb = sizeof(STARTUPINFO);

PROCESS_INFORMATION pf;

::CreateProcess(NULL, str.GetBuffer(), NULL, NULL, FALSE, CREATE_NEW_CONSOLE, NULL, NULL, &si, &pf);

}

ct = CTime::GetCurrentTime();

temp.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << "主console程序结束时间：" << temp << endl;

return nRetCode;

}

// c.cpp : 定义控制台应用程序的入口点。

#include "stdafx.h"

#include "c.h"

#include "DataAccess.h"

#include <fstream>

using namespace std;

#ifdef _DEBUG

#define new DEBUG_NEW

#endif

// 唯一的应用程序对象

CWinApp theApp;

using namespace std;

int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])

{

int nRetCode = 0;

ofstream file("test.txt",std::ios::app);

CTime ct;

CString text;

ct = CTime::GetCurrentTime();

text.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << argv[1] << "开始时间：" << text << endl;

CoInitialize(NULL);

// 初始化 MFC 并在失败时显示错误

if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))

{

// TODO: 更改错误代码以符合您的需要

_tprintf(_T("致命错误: MFC 初始化失败\n"));

nRetCode = 1;

}

else

{

// TODO: 在此处为应用程序的行为编写代码。

CAdoConnection AdoConnection;

CAdoCommand AdoCommand;

AdoConnection.ConnectingString = "Provider=SQLOLEDB;Network Address=127.0.0.1;Initial Catalog=临时数据库";

AdoConnection.UserName = "sa";

AdoConnection.PassWord = "sa";

if (AdoConnection.Connected == FALSE)

AdoConnection.Connected = TRUE;

AdoCommand.CommandType = adCmdText;

AdoCommand.CommandText = string("INSERT INTO ") + string(argv[1]) + string(" (name) VALUES ('ghb')");

AdoCommand.m_AdoConnection = &AdoConnection;

for (int i = 0; i<200000; i++)

AdoCommand.Execute();

AdoConnection.Connected = FALSE;

}

CoUninitialize();

ct = CTime::GetCurrentTime();

text.Format("%d分%d秒", ct.GetMinute(), ct.GetSecond());

file << argv[1] << "结束时间：" << text << endl;

return nRetCode;

}