Android sqlite数据库连接池连接异常分析

比眉伴天荒 2022-06-04 04:41 271阅读 0赞

转：[http://bbs.51cto.com/thread-1113117-1.html][http_bbs.51cto.com_thread-1113117-1.html]

Android sqlite数据库连接池连接异常分析  
  
1． 在android开发过程中，突然碰到了这个错误，数据库连接分配不到，日志如下：  
W/SQLiteConnectionPool( 3681): Theconnection pool for database '/data/user/0/com.android.providers.contacts/databases/contacts2.db'has been unable to grant a connection to thread 371 (ContactsProviderWorker)with flags 0x1 for 30.000002 seconds.  
W/SQLiteConnectionPool( 3681): Connections:0 active, 1 idle, 0 available.  
  
  
2． 网上别人的总结  
搜索了上面错误日志，找到别人的解决方法：  
  
![attachimg.gif][]![wKiom1OoFBmzmtoqAAD9uWMt5t0364.jpg][]

![image.gif][] [**1.png**][1.png] (62.72 KB)

2014-6-23 19:43

他说是在一个Transaction 里面又执行一个execSql(sql) 导致。但是经过自己的分析发现，完全不是这么回事。可见，网络上很多东西都是不可全信的。  
为什么这么说呢，我们首先来分析下整个数据库连接的获取过程，一般进行下列操作时都会申请获取一个数据库连接。  
a.  
Query, insert, delete 操作  
b.  
beginTranscation 操作  
从网上截了个图，让大家看的更清楚点  
  
![attachimg.gif][] ![wKioL1OoE-uRWXxcAAF4dtH9iXA807.jpg][]

![image.gif][] [**2.png**][2.png] (91.23 KB)

2014-6-23 19:43

Ok... 那么我们就以insert 操作为例，说明数据库连接获取的流程。  
  
  
1．  
 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>SqliteDatabase的insert方法</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>02</code></td> 
   <td><code>public</code> <code> long</code> <code>insert(String table, StringnullColumnHack, ContentValues values) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>return</code> <code> insertWithOnConflict(table, nullColumnHack, values,CONFLICT_NONE);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>} </code><code>catch</code><code>(SQLException e) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>Log.e(TAG, </code><code>"Error inserting "</code><code>+ values, e);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td><code>return</code> <code> -</code><code>1</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

2．  
 Ok... 继续往下面分析insertWithOnConflict方法 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>public</code> <code> long</code> <code>insertWithOnConflict(Stringtable, String nullColumnHack,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>ContentValues initialValues, </code> <code>int</code> <code>conflictAlgorithm) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>acquireReference();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>StringBuilder sql = </code><code>new</code><code>StringBuilder();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>sql.append(</code><code>"INSERT"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>sql.append(CONFLICT_VALUES[conflictAlgorithm]);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>sql.append(</code><code>" INTO "</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>sql.append(</code><code>')'</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>23</code></td> 
   <td><code>SQLiteStatement statement = </code><code>new</code><code>SQLiteStatement(</code><code>this</code><code>, sql.toString(),bindArgs);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>27</code></td> 
   <td><code>returnstatement.executeInsert();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>29</code></td> 
   <td><code>} </code><code>finally</code><code>{ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>31</code></td> 
   <td><code>statement.close();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>35</code></td> 
   <td><code>} </code><code>finally</code><code>{ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>37</code></td> 
   <td><code>releaseReference();</code></td> 
  </tr> 
 </tbody> 
</table>

这个方法首先构造insert的sql语句，然后调用statement的executeInsert()方法  
那继续跟下去  
3．  
 frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteStatement.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>public</code> <code> long</code> <code>executeInsert() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>return</code> <code> getSession().executeForLastInsertedRowId(</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>getSql(), getBindArgs(), getConnectionFlags(),</code><code>null</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

这个方法比较重要，分成两步来分析：  
首先分析getSession()方法，  
然后再去看看executeForLastInsertedRowId方法。  
  
  
3a. getSession分析 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>frameworks\base\core\java\android\database\sqlite\SQLiteProgram.java</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>02</code></td> 
   <td><code>protected</code> <code> final</code> <code>SQLiteSession getSession(){ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td><code>return</code> <code> mDatabase.getThreadSession();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>3b. 调用的是SqliteDatabase.getThreadSession()方法，继续分析</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>frameworks\base\core\java\android\database\sqlite\SQLiteDatabase.java</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>SQLiteSession getThreadSession() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>return</code> <code> mThreadSession.get(); </code><code>// initialValue() throws if database closed</code></td> 
  </tr> 
 </tbody> 
</table>

调用的是mThreadSession.get()，看看mThreadSession是什么东西 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>private</code> <code> final</code> <code>ThreadLocal&lt;SQLiteSession&gt;mThreadSession = </code> <code>new</code> <code>ThreadLocal&lt;SQLiteSession&gt;() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>protected</code> <code> SQLiteSession initialValue() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>return</code> <code> createSession();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>SQLiteSession createSession() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>final</code> <code> SQLiteConnectionPool pool;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>synchronized</code> <code> (mLock) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>17</code></td> 
   <td><code>pool = mConnectionPoolLocked;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>21</code></td> 
   <td><code>return</code> <code> new</code> <code>SQLiteSession(pool);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>26</code></td> 
   <td><code>public</code> <code> SQLiteSession(SQLiteConnectionPoolconnectionPool) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>28</code></td> 
   <td><code>if</code> <code> (connectionPool == </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>30</code></td> 
   <td><code>throw</code> <code> new</code> <code>IllegalArgumentException(</code><code>"connectionPool must not benull"</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>34</code></td> 
   <td><code>mConnectionPool = connectionPool;</code></td> 
  </tr> 
 </tbody> 
</table>

嗯，非常明白，这是一个ThreadLocal类型的变量，ThreadLocal，Java提供的一个用于多线程之间隔离数据的东西，避免多线程访问同一个变量导致冲突。  
也就是ThreadLocal是为每个线程保存一份变量，这样就不会引起冲突了。这个ThreadLocal如果有不理解的，可以百度下ThreadLocal的使用。  
  
  
Ok..理解完ThreadLocal之后，继续看createSession方法  
它是使用mConnectionPoolLocked这么个SQLiteConnectionPool变量来实例化一个SQLiteSession对象。而这个mConnectionPoolLocked对象是SqliteDatabase打开的时候实例化的，也就是说一个database只有一个这样连接。  
那么，这里我们可以理清楚一个关系  
a.  
 一个线程会对应一个SqliteSession对象，这个是用ThreadLocal对象来维持的。  
b.  
 一个数据库对应唯一一个sqliteDabase对象，以及唯一一个SQLiteConnectionPool对象，然后各个线程之间共享这个SQLiteConnectionPool对象。  
Ok..理清楚这几个关系之后，返回去分析executeForLastInsertedRowId方法  
  
  
4．  
 frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteSession.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>public</code> <code> long</code> <code>executeForLastInsertedRowId(Stringsql, Object[] bindArgs,</code><code>int</code> <code>connectionFlags,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>CancellationSignal cancellationSignal) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>acquireConnection(sql, connectionFlags, cancellationSignal);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>return</code> <code> mConnection.executeForLastInsertedRowId(sql, bindArgs,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>cancellationSignal); </code><code>//might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>} </code><code>finally</code><code>{ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>17</code></td> 
   <td><code>releaseConnection(); </code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

这个方法主要分析两个操作  
acquireConnection  
releaseConnection  
因为中间的mConnection.executeForLastInsertedRowId语句主要是通过Jni往底层调用，插入数据库数据，不是今天我们讨论的话题。  
Ok.. 那这两个操作，一个个来分析  
4a. acquireConnection  
frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteSession.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>private</code> <code> void</code> <code>acquireConnection(String sql,</code><code>int</code><code>connectionFlags,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>CancellationSignal cancellationSignal) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>if</code> <code> (mConnection == </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>assert</code> <code> mConnectionUseCount == </code><code>0</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>mConnection = mConnectionPool.acquireConnection(sql, connectionFlags,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td><code>cancellationSignal); </code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>14</code></td> 
   <td><code>mConnectionFlags = connectionFlags;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>mConnectionUseCount += </code><code>1</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

Ok..首先会去判断当前线程的Session里面的mConnection是否为null,如果不为null，就只是简单的把连接个数mConnectionUseCount加1  
如果为null，也就是当前线程的Session没有连接数据库，那么就要去申请一个连接。  
  
  
所以这里的逻辑特别重要，就是一个对于一个线程而已，它只会去获取一次数据库连接。即使你调用再多的beginTranscation以及query，第一次调用的时候会去获取连接，以后就是让mConnectionUseCount 加1；  
当然，你使用beginTranscation需要手动调用endTranscation，不然不会去释放连接。  
调用其他的，比如query，insert之类的，不需要手动释放。系统会帮你去调用释放连接。  
Ok.. 接下来分析mConnectionPool.acquireConnection的流程.  
  
  
4b. 调用mConnectionPool.acquireConnection，顾名思义，它是向连接池申请一个连接；根据之前的分析，这个连接池是唯一的，是多个线程之间共享的。  
frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteConnectionPool.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>001</code></td> 
   <td><code>public</code> <code> SQLiteConnectionacquireConnection(String sql, </code><code>int</code><code>connectionFlags,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>003</code></td> 
   <td><code>CancellationSignal cancellationSignal) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>005</code></td> 
   <td><code>return</code> <code> waitForConnection(sql, connectionFlags, cancellationSignal);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>012</code></td> 
   <td><code>private</code> <code> SQLiteConnectionwaitForConnection(String sql, </code><code>int</code><code>connectionFlags,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>014</code></td> 
   <td><code>CancellationSignal cancellationSignal) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>016</code></td> 
   <td><code>final</code> <code> boolean</code> <code>wantPrimaryConnection =</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>018</code></td> 
   <td><code>(connectionFlags &amp;CONNECTION_FLAG_PRIMARY_CONNECTION_AFFINITY) !=</code><code>0</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>022</code></td> 
   <td><code>final</code> <code> ConnectionWaiter waiter;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>024</code></td> 
   <td><code>final</code> <code> int</code> <code>nonce;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>026</code></td> 
   <td><code>synchronized</code> <code> (mLock) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>028</code></td> 
   <td><code>throwIfClosedLocked();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>032</code></td> 
   <td><code>// Abort if canceled.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>034</code></td> 
   <td><code>if</code> <code> (cancellationSignal != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>036</code></td> 
   <td><code>cancellationSignal.throwIfCanceled();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>042</code></td> 
   <td><code>// Try to acquire a connection.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>044</code></td> 
   <td><code>SQLiteConnection connection = </code> <code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>046</code></td> 
   <td><code>if</code> <code> (!wantPrimaryConnection) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>047</code></td> 
   <td><code>//尝试获取非主连接</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>049</code></td> 
   <td><code>connection =tryAcquireNonPrimaryConnectionLocked(</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>051</code></td> 
   <td><code>sql, connectionFlags);</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>055</code></td> 
   <td><code>if</code> <code> (connection == </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>056</code></td> 
   <td><code>//尝试去获取主连接</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>058</code></td> 
   <td><code>connection =tryAcquirePrimaryConnectionLocked(connectionFlags);</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>062</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>063</code></td> 
   <td><code>//获取到连接后，返回连接</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>065</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>069</code></td> 
   <td><code>//没有获取到连接，新建一个waiter对象，加入等待队列</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>072</code></td> 
   <td><code>// No connections available.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>073</code></td> 
   <td><code>Enqueue a waiter in priority order.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>075</code></td> 
   <td><code>final</code> <code> int</code> <code>priority = getPriority(connectionFlags);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>077</code></td> 
   <td><code>final</code> <code> long</code> <code>startTime = SystemClock.uptimeMillis();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>079</code></td> 
   <td><code>waiter = obtainConnectionWaiterLocked(Thread.currentThread(), startTime,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>081</code></td> 
   <td><code>priority,wantPrimaryConnection, sql, connectionFlags);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>083</code></td> 
   <td><code>ConnectionWaiter predecessor = </code> <code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>085</code></td> 
   <td><code>ConnectionWaiter successor = mConnectionWaiterQueue;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>087</code></td> 
   <td><code>while</code> <code> (successor != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>090</code></td> 
   <td><code>if</code> <code> (priority &gt;successor.mPriority) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>092</code></td> 
   <td><code>waiter.mNext = successor;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>094</code></td> 
   <td><code>break</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>098</code></td> 
   <td><code>predecessor = successor;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>100</code></td> 
   <td><code>successor = successor.mNext;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>104</code></td> 
   <td><code>if</code> <code> (predecessor != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>106</code></td> 
   <td><code>predecessor.mNext = waiter;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>110</code></td> 
   <td><code>mConnectionWaiterQueue =waiter;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>116</code></td> 
   <td><code>nonce = waiter.mNonce;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>126</code></td> 
   <td><code>//把当前线程睡眠30s，然后尝试去获取连接，如果没有获取到连接，则打印当前线程的等待时间。</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>130</code></td> 
   <td><code>// Park the thread until a connection is assigned or the pool is closed.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>132</code></td> 
   <td><code>// Rethrow an exception from the wait, if we got one.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>134</code></td> 
   <td><code>long</code> <code> busyTimeoutMillis = CONNECTION_POOL_BUSY_MILLIS;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>137</code></td> 
   <td><code>long</code> <code> nextBusyTimeoutTime = waiter.mStartTime + busyTimeoutMillis;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>141</code></td> 
   <td><code>// Detect and recover fromconnection leaks.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>143</code></td> 
   <td><code>if</code><code>(mConnectionLeaked.compareAndSet(</code><code>true</code><code>,</code><code>false</code><code>)) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>146</code></td> 
   <td><code>synchronized</code> <code> (mLock) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>148</code></td> 
   <td><code>wakeConnectionWaitersLocked();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>155</code></td> 
   <td><code>// Wait to be unparked (mayalready have happened), a timeout, or interruption.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>157</code></td> 
   <td><code>LockSupport.parkNanos(</code><code>this</code><code>,busyTimeoutMillis * 1000000L);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>158</code></td> 
   <td><code>//当前线程停止30s</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>162</code></td> 
   <td><code>// Clear the interrupted flag,just in case.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>164</code></td> 
   <td><code>Thread.interrupted();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>168</code></td> 
   <td><code>// Check whether we are donewaiting yet.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>170</code></td> 
   <td><code>synchronized</code> <code> (mLock) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>172</code></td> 
   <td><code>throwIfClosedLocked();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>174</code></td> 
   <td><code>final</code> <code> SQLiteConnectionconnection = waiter.mAssignedConnection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>176</code></td> 
   <td><code>final</code> <code> RuntimeException ex =waiter.mException;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>178</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code> <code> ||ex != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>180</code></td> 
   <td><code>recycleConnectionWaiterLocked(waiter);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>182</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code><code>){ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>184</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>188</code></td> 
   <td><code>throw</code> <code> ex; </code><code>// rethrow!</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>195</code></td> 
   <td><code>final</code> <code> long</code> <code>now =SystemClock.uptimeMillis();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>197</code></td> 
   <td><code>if</code> <code> (now &lt;nextBusyTimeoutTime) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>199</code></td> 
   <td><code>busyTimeoutMillis = now- nextBusyTimeoutTime;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>203</code></td> 
   <td><code>logConnectionPoolBusyLocked(now- waiter.mStartTime, connectionFlags);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>204</code></td> 
   <td><code>//打印出当前线程等待的时间</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>206</code></td> 
   <td><code>busyTimeoutMillis =CONNECTION_POOL_BUSY_MILLIS;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>208</code></td> 
   <td><code>nextBusyTimeoutTime =now + busyTimeoutMillis;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>216</code></td> 
   <td><code>} </code><code>finally</code><code>{ </code></td> 
  </tr> 
 </tbody> 
</table>

这个方法比较多，我在里面做了一点注释，大概包括下面几个步骤。同时要明确一个概念，主连接和非主连接。  
其实他们没有本质的区别，主连接是一定有的，在初始化的时候就实例化完毕；而非主连接是一个连接集合，也就是说非主连接可以有很多个。不过一般有个最大大小，我们可以配置的。  
Ok...明白这个概念之后，讲讲步骤  
a.  
 如果没有指定要获取主连接的话，首先尝试获取非主连接 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>private</code> <code> SQLiteConnectiontryAcquireNonPrimaryConnectionLocked(</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>String sql, </code><code>int</code><code>connectionFlags) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>// Try to acquire the next connection in the queue.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>SQLiteConnection connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>final</code> <code> int</code> <code>availableCount = mAvailableNonPrimaryConnections.size();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>if</code> <code> (availableCount &gt; </code><code>1</code> <code> &amp;&amp; sql != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>// If we have a choice, then prefer a connection that has the</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>15</code></td> 
   <td><code>// prepared statement in its cache.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>for</code> <code> (</code><code>int</code> <code>i = </code> <code>0</code><code>; i &lt;availableCount; i++) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>20</code></td> 
   <td><code>connection =mAvailableNonPrimaryConnections.get(i);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>22</code></td> 
   <td><code>if</code><code>(connection.isPreparedStatementInCache(sql)) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>24</code></td> 
   <td><code>mAvailableNonPrimaryConnections.remove(i);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>27</code></td> 
   <td><code>finishAcquireConnectionLocked(connection,connectionFlags);</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>29</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>37</code></td> 
   <td><code>if</code> <code> (availableCount &gt; </code><code>0</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>39</code></td> 
   <td><code>// Otherwise, just grab the next one.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>42</code></td> 
   <td><code>connection =mAvailableNonPrimaryConnections.remove(availableCount -</code><code>1</code><code>);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>44</code></td> 
   <td><code>finishAcquireConnectionLocked(connection, connectionFlags);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>46</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>52</code></td> 
   <td><code>// Expand the pool if needed.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>54</code></td> 
   <td><code>int</code> <code> openConnections = mAcquiredConnections.size();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>56</code></td> 
   <td><code>if</code> <code> (mAvailablePrimaryConnection != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>58</code></td> 
   <td><code>openConnections += </code><code>1</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>65</code></td> 
   <td><code>if</code> <code> (openConnections &gt;= mMaxConnectionPoolSize) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>67</code></td> 
   <td><code>return</code> <code> null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>71</code></td> 
   <td><code>connection = openConnectionLocked(mConfiguration,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>73</code></td> 
   <td><code>false</code> <code> /*primaryConnection*/</code><code>);</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>75</code></td> 
   <td><code>finishAcquireConnectionLocked(connection, connectionFlags);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>77</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

获取非主连接的时候，首先会判断已有的连接中有没有相同的sql，如果有的话，就直接返回这个连接。  
然后如果第一步没有成功的话，比如传入的sql是null，那么就会尝试获取队列里面的最后一个连接，然后返回。  
如果第二步也没有成功，那么它会尝试去扩充非主连接集合  
但是，它会去判断是否超过了最大的连接数，是已经到达最大的连接数，那么就返回null ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>1</code></td> 
   <td><code>if</code> <code> (openConnections &gt;=mMaxConnectionPoolSize) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>3</code></td> 
   <td><code>return</code> <code> null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

如果还没有到达最大连接数，那么就把连接放入非主连接集合，然后返回这个扩容的连接。  
  
  
b.  
 如果没有获取到非主连接，或者指定要获取主连接，那么就要去尝试获取主连接。 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>private</code> <code> SQLiteConnectiontryAcquirePrimaryConnectionLocked(</code><code>int</code><code>connectionFlags) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>03</code></td> 
   <td><code>// If the primary connection is available, acquire it now.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>05</code></td> 
   <td><code>SQLiteConnection connection = mAvailablePrimaryConnection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>07</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>mAvailablePrimaryConnection = </code> <code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>finishAcquireConnectionLocked(connection, connectionFlags);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>19</code></td> 
   <td><code>// Make sure that the primary connection actually exists and has justbeen acquired.</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>21</code></td> 
   <td><code>for</code> <code> (SQLiteConnection acquiredConnection :mAcquiredConnections.keySet()) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>23</code></td> 
   <td><code>if</code> <code> (acquiredConnection.isPrimaryConnection()) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>25</code></td> 
   <td><code>return</code> <code> null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>35</code></td> 
   <td><code>No primaryconnection!</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>36</code></td> 
   <td><code>Either </code><code>this</code><code>is the firsttime we asked</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>38</code></td> 
   <td><code>// for it, or maybe it leaked?</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>40</code></td> 
   <td><code>connection = openConnectionLocked(mConfiguration,</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>42</code></td> 
   <td><code>true</code> <code> /*primaryConnection*/</code><code>); </code><code>//might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>44</code></td> 
   <td><code>finishAcquireConnectionLocked(connection, connectionFlags);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>46</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

由于主连接只有一个，所以它用一个变量来表示 --- mAvailablePrimaryConnection  
如果主连接为null就返回主连接，并把主连接设置成null，也就是主连接被占用。 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>1</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>3</code></td> 
   <td><code>mAvailablePrimaryConnection = </code> <code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>5</code></td> 
   <td><code>finishAcquireConnectionLocked(connection, connectionFlags);</code><code>// mightthrow</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>7</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

如果主连接为null，那么它会去查看是否已经有人获取了主连接，如果是，那么返回null；这样做就是确保主连接是存在的。  
如果经过上面一步确认，还没有返回，那么说明主连接没有创建；这个一般是不可能的，因为主连接时数据库初始化的时候创建的。这个一般是第一次访问，或者出现了程序异常。那么就新建一个主连接，然后返回。  
  
  
c.  
 如果获取到连接，那么返回这个连接 ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>1</code></td> 
   <td><code>if</code> <code> (connection != </code><code>null</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>3</code></td> 
   <td><code>return</code> <code> connection;</code></td> 
  </tr> 
 </tbody> 
</table>

d.  
 如果没有获取到连接，那么新建一个waiter对象，并进入等待队列。  
e.  
 线程进入死循环，不断休眠(30s)，然后重新获取连接。直到获取到连接后返回。否则，记录下当前线程等待的时间。不过这里要注意，这里打印的等待时间并不包括系统睡眠的时间。比如，下午1点进入等待，2点-4点手机睡眠，那么到5点的时候打印，只能算两个小时。  
也就是上面我们看到的异常日志：  
04-2314:25:48.522 W/SQLiteConnectionPool( 3681): The connection pool for database'/data/user/0/com.android.providers.contacts/databases/contacts2.db' has beenunable to grant a connection to thread 371 (ContactsProviderWorker) with flags0x1 for 30.000002 seconds.  
04-23 14:25:48.522 W/SQLiteConnectionPool( 3681):Connections: 0 active, 1 idle, 0 available.  
  
  
Ok...至此，整个申请数据库连接过程分析基本完毕，下面分析释放的过程  
  
  
5．释放连接  
frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteSession.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>finally</code> <code> { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>02</code></td> 
   <td><code>releaseConnection();</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>06</code></td> 
   <td><code>private</code> <code> void</code> <code>releaseConnection() { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>09</code></td> 
   <td><code>assert</code> <code> mConnection != </code><code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>11</code></td> 
   <td><code>assert</code> <code> mConnectionUseCount &gt; </code><code>0</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>13</code></td> 
   <td><code>if</code> <code> (--mConnectionUseCount == </code><code>0</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>mConnectionPool.releaseConnection(mConnection);</code><code>// might throw</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>20</code></td> 
   <td><code>} </code><code>finally</code><code>{ </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>22</code></td> 
   <td><code>mConnection = </code><code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

首先会去判断当前使用数是否为大于0，还记得前面我们说过如果线程第一次申请连接，那么就去申请，然后使用数+1；但是如果线程已经拥有了连接，那么我们只是简单的把连接数+1。  
所以，这里要判断这个连接数是否>0  
然后把连接数减去1，看是否等于0；这是什么意思呢？就是说当前线程已经没有使用数据库的操作了。  
如果减去1之后>0，那么说明当前线程还要使用这个连接操作数据库，还不能释放。  
这里也可以看出，申请连接和释放连接一定要是一一对应的。申请了，一定要释放。当然，对于应用程序来说，只有beginTranscation需要手动去释放，也就是调用endTranscation，而且必须要调用(一般写在finally里面)。  
Ok...一切都ok的话，正式去释放连接  
mConnectionPool.releaseConnection(mConnection);// might throw  
  
  
5a. 正式释放连接  
frameworks\\base\\core\\java\\android\\database\\sqlite\\SQLiteConnectionPool.java ``

[预览源代码][Link 1]

[打印][Link 2]

<table> 
 <tbody> 
  <tr> 
   <td><code>01</code></td> 
   <td><code>public</code> <code> voidreleaseConnection(SQLiteConnection connection) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>04</code></td> 
   <td><code>synchronized</code> <code> (mLock) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>08</code></td> 
   <td><code>if</code> <code> (!mIsOpen) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>10</code></td> 
   <td><code>closeConnectionAndLogExceptionsLocked(connection);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>12</code></td> 
   <td><code>} </code><code>else</code><code>if</code> <code>(connection.isPrimaryConnection()) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>14</code></td> 
   <td><code>if</code><code>(recycleConnectionLocked(connection, status)) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>16</code></td> 
   <td><code>assert</code> <code> mAvailablePrimaryConnection== </code><code>null</code><code>;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>18</code></td> 
   <td><code>mAvailablePrimaryConnection= connection;</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>22</code></td> 
   <td><code>wakeConnectionWaitersLocked();</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>24</code></td> 
   <td><code>} </code><code>else</code><code>if</code> <code>(mAvailableNonPrimaryConnections.size() &gt;=mMaxConnectionPoolSize -</code><code>1</code><code>) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>26</code></td> 
   <td><code>closeConnectionAndLogExceptionsLocked(connection);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>30</code></td> 
   <td><code>if</code><code>(recycleConnectionLocked(connection, status)) { </code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>32</code></td> 
   <td><code>mAvailableNonPrimaryConnections.add(connection);</code></td> 
  </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
  <tr> 
   <td><code>37</code></td> 
   <td><code>wakeConnectionWaitersLocked();</code></td> 
  </tr> 
 </tbody> 
</table>

这里会去根据当前连接是否是主连接而选择释放方法，然后通知那些正在等待的线程(waiter)去获取连接。  
  
  
6. 总结  
1． 如文章开头所说，这个bug不是由于在beginTranscation里面执行一个execuSql(sql)所导致的，因为在同一个线程里面，即使申请两次数据库连接，那也只是让使用数+1而已。它只会去申请一个连接。除非beginTranscation和execuSql(sql) 不在一个线程，另外开线程去execuSql(sql).  
2． 那么怎么会导致这个bug呢？  
a. 时间过长的操作，某个操作持续很长时间，那么其他线程等待的时候就会打印这个信息。不过，一般不会等待太久。因为一般不会有这么长时间的数据库操作。  
b. 忘记调用endTranscation，如前面所说，只有beginTranscation需要程序员手动去调用endTransction来释放连接，其他操作不需要。  
那么，有个时候会疏忽忘记调用endTransction了。  
或者endTranscation没有放在finally里面，导致出现异常而没有调用endTransction  
 c.  
 死锁，这个比较复杂，需要具体问题具体分析。  
如果出现死锁，线程互相等待，这样也没有去释放连接；那么后面的线程自然也拿不到数据库连接了。  
  
  
  
  
参考资料  
[http://blog.csdn.net/efeics/article/details/18970483][http_blog.csdn.net_efeics_article_details_18970483]

[http_bbs.51cto.com_thread-1113117-1.html]: http://bbs.51cto.com/thread-1113117-1.html
[attachimg.gif]: http://bbs.51cto.com/images/default/attachimg.gif
[wKiom1OoFBmzmtoqAAD9uWMt5t0364.jpg]: /images/20220604/36a2d2d1a9364b448a90daae12b813ac.png
[image.gif]: http://bbs.51cto.com/images/attachicons/image.gif
[1.png]: http://bbs.51cto.com/attachment.php?aid=282823&k=e04ab908130046657a4944008ca14302&t=1512369113&nothumb=yes
[wKioL1OoE-uRWXxcAAF4dtH9iXA807.jpg]: /images/20220604/169fbd610155494ca3a11f2d8c17f3c6.png
[2.png]: http://bbs.51cto.com/attachment.php?aid=282824&k=93e955dc9e41bff6222f43d675f336f3&t=1512369113&nothumb=yes
[Link 1]: http://bbs.51cto.com/thread-1113117-1.html#viewSource
[Link 2]: http://bbs.51cto.com/thread-1113117-1.html#printSource
[http_blog.csdn.net_efeics_article_details_18970483]: http://blog.csdn.net/efeics/article/details/18970483