多线程数据库连接
是的。肯定要每次都连接数据库，简单点
你可以把连接数据库写成一个类中的方法，到run（）线程的时候，创建类的对象，再调用就好了。
② 大家是如何处理很多线程连接数据库连接的
连接数据库要连接池，就是connection对象要放在一个LinkedList里面，然后每个线程一个。这个这个List被封装在一个单例模式的对象里。线程要是共享connection，要是搞起并发来，一下子就挂了。
③ 多线程并发访问数据库中不同记录时应该采用什么办法
多个线程在访问同一个数据库中的记录的时候，在大并发的情况下，一定要做好事务机制。要不然后果还是很扎心的。可能遇到这样的问题的时候首先想到的就是同步锁机制了。
并发产生的情况
其实在实际项目开发汇总，首先要做的就是避免多个线程共用一个数据库连接，这样会很容易出问题，最好是一个线程一个连接。在必要的时候需要线程同步或存储过程加锁。如果有比较复杂的事务操作的话就需要加锁了，如果不加的话就会出现你说的脏读、死锁等问题。
④ 请教如何进行多线程连接数据库并写入数据
#include <QCoreApplication>
#include "thread.h"
#include <QVector>
#include <QDebug>
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
QVector<Thread*> vector;
Thread *thread;
//创建多个线程，并start
for(int i=0;i<10;i++){
thread=new Thread;
vector.append(thread);
thread->set(i);
thread->start();
}
//等待所有线程执行完，然后删除线程
foreach(thread,vector){
thread->wait();
}
foreach(thread,vector){
delete thread;
}
return a.exec();
}
-------------------------------------------------------------------------------------------------
#include "thread.h"
Thread::Thread(QObject *parent) : QThread(parent)
{
}
void Thread::run()
{
begin();
}
//为每个线程创建一个连接名
void Thread::set(int a)
{
connectionName=QString::number(a);
}
void Thread::connectionDatabase(QString dbName)
{
QsqlDatabasedb=QSqlDatabase::addDatabase("QMYSQL",connectionName);
db.setHostName("localhost");
db.setDatabaseName(dbName);
db.setUserName("root");
db.setPassword("");
if(!db.open())
qDebug()<<"db open fail";
}
void Thread::begin()
{
QString dbName="learnsql";
connectionDatabase(dbName);
QSqlDatabase db=QSqlDatabase::database(connectionName);
db.transaction(); //开启事物
QSqlQuery query(db);
//向表student中插入10000条数据
for(int i=1;i<=10000;i++){
query.exec("insert into student values(1)");
}
db.commit(); //提交事物
}
⑤ 多线程如何并发访问SQLite数据库
SQLite作为一款小型的嵌入式数据库，本身没有提供复杂的锁定机制，无法内部管理多路并发下的数据操作同步问题，更谈不上优化，所以涉及到多路并发的情况，需要外部进行读写锁控制，否则SQLite会返回SQLITE_BUSY错误，以驳回相关请求。
返回SQLITE_BUSY主要有以下几种情况：
1。当有写操作时，其他读操作会被驳回
2。当有写操作时，其他写操作会被驳回
3。当开启事务时，在提交事务之前，其他写操作会被驳回
4。当开启事务时，在提交事务之前，其他事务请求会被驳回
5。当有读操作时，其他写操作会被驳回
6。读操作之间能够并发执行
基于以上讨论，可以看出这是一个典型的读者写者问题，读操作要能够共享，写操作要互斥，读写之间也要互斥
可以设计如下的方案解决并发操作数据库被锁定的问题，同时保证读操作能够保持最大并发
1。采用互斥锁控制数据库写操作
2。只有拥有互斥锁的线程才能够操作数据库
3。写操作必须独立拥有互斥锁
4。读操作必须能够共享互斥锁，即在第一次读取的时候获取互斥锁，最后一次读取的时候释放互斥锁
⑥ 多线程访问数据库问题
这个要看情况。
不同的数据库情况不一样。
一般说来是可以每个线程使用一个连接的（有时候会出现很难查找的奇怪问题）
保险一点还是共用一个连接 互斥占用。
⑦ java爬虫采用多线程，数据库连接多了就报异常
可以通过测试对错误原因进行排查，如果连接少量时不出问题，那就是连接量超出了某一数值出现异常，可以查看数据库的链接上限，如果是连接上限原因，可以尝试上调上限或者降低连接数量
⑧ 多线程 连接数据库,C#多线程写数据库
多线程连接数据库的连接池类：
public static class ConnectionPool
{
private static object locker = new object();
private static Dictionary<string, SqlConnection> Connections = null;
public static SqlConnection GetConnection<T>() where T : class, new()
{
string databaseName = NA.Common.Extensions.GetDatabaseName<T>();
if (string.IsNullOrEmpty(databaseName))
return null;
if (Connections == null)
{
lock (locker)
{
Connections = new Dictionary<string, SqlConnection>();
}
}
string connKey = FindFreeSqlConnection(databaseName);
if (connKey != null)
return Connections[connKey];
else
{
string strconn = NA.Common.Extensions.GetConnectionString<T>();
int poolSize = NA.Common.Extensions.GetConnectionPoolSize<T>();
lock (locker)
{
for (int i = 0; i < poolSize; ++i)
{
SqlConnection conn = new SqlConnection(strconn);
conn.Open();
Connections.Add(databaseName + "_" + i.ToString(), conn);
conn.Close();
}
}
return Connections[FindFreeSqlConnection(databaseName)];
}
}
private static string FindFreeSqlConnection(string databaseName)
{
IEnumerable<string> connKeys = Connections.Keys.Where(item => item.StartsWith(databaseName));
if (connKeys != null && connKeys.Count() > 0)
{
foreach (string key in connKeys)
{
if (Connections[key].State == ConnectionState.Closed)
return key;
}
}
return null;
}
}
附加上其中用到的三个方法：
internal static int GetConnectionPoolSize<T>() where T : class, new()
{
string database = GetDatabaseName<T>();
string[] poolSizeArray = ConfigurationManager.AppSettings["ConnectionsPoolSize"].Split('|');
if (poolSizeArray != null)
{
foreach (string sizeItem in poolSizeArray)
{
string[] sizeItemArray = sizeItem.Split(':');
if (database == sizeItemArray[0])
return int.Parse(sizeItemArray[1]);
}
}
return 50;
}
public static string GetConnectionString<T>() where T : class, new()
{
string tableName = GetTableName<T>();
string[] databaseArray = ConfigurationManager.AppSettings["DatabaseArray"].Split('|');
if (databaseArray != null)
{
foreach (string database in databaseArray)
{
string tableNameList = ConfigurationManager.AppSettings[database];
string[] tables = ConfigurationManager.AppSettings[database].Split('|');
if (tables != null && tables.Length > 0)
if (tables.Contains(tableName))
return ConfigurationManager.ConnectionStrings[database].ConnectionString;
}
}
return string.Empty;
}
public static string GetDatabaseName<T>() where T : class, new()
{
string tableName = GetTableName<T>();
string[] databaseArray = ConfigurationManager.AppSettings["DatabaseArray"].Split('|');
if (databaseArray != null)
{
foreach (string database in databaseArray)
{
string tableNameList = ConfigurationManager.AppSettings[database];
string[] tables = ConfigurationManager.AppSettings[database].Split('|');
if (tables != null && tables.Length > 0)
if (tables.Contains(tableName))
return database;
}
}
return string.Empty;
}