dbms_lock统制串行详解 1 使用dbms_lock包控制串行 FtpClient 种来操作FTP的上传和下载，带进度条 Hadoop入门1：Hadoop简介-IT货架

在pl/sql代码块中，有些操作代码块不能被多个会话同时进行执行，比如生成中间数据表（如先清除，后插入中间数据），

并且此表的数据在后续业务处理总需要使用，如果此部分代码块被另个会话调用，则会造成中间数据表的数据在同一个会话中不完整。

因此当有类似这样的需求时，就可能需要在pl/sql块中使用dbms_lock包控制来控制此部分代码块只能进行串行调用。

1.1 锁定原理

1.1.1 用户锁概念

1、通过dbms_lock获取的锁类型可以看成是oracle内部的一种队列锁，用户申请时通过指定的锁ID或通过指定需要锁定的名称

（此时会返回一个锁ID给用户）来获取锁定并独占此ID代表的信号量，从而达到控制并发的，因此称为用户锁(PL/SQL用户锁)。

2、用户锁有别于物理概念上的锁（如DML lock（data lock），DDL lock（dictionary lock)和internal lock/latch），可以看成是逻辑上的一种锁定，

且他们两者之间也是不相冲突的。比如如果会话1基于某个物理表的表明定义了一用户锁，此时会话2实际上是可以对此物理表做任何DDL,DML操作的。

1.1.2 锁定模式

用户申请锁时可以指定锁定模式（默认为x_mode），这里的锁定模式逻辑上可以对应到TM锁中的模式，有以下六种模式。

1.1.2.1 锁定模式与并发度

需要注意的是，用户锁的锁定模式仅仅来用控制当其他会话试图获取自身会话所占有的锁ID（信号量）时，获取操作是成功、阻塞，

1.1.3 查看

1.2 申请用户锁

申请用户锁时有两种方式，分别通过指定的锁ID或通过指定锁名称（此时会返回一个锁ID给用户）来获取锁定并独占此ID，其返回值为integer, 含义如下，其中1和4代表申请成功：

0 申请锁定成功
　　1 申请锁定时超时
　　2 申请锁定时发生死锁
　　3 传入参数错误
　　4 已经获得了锁定，重复申请了锁
　　5 传入的锁定句柄错误

1.2.1 通过指定锁ID

此种方式不建议，因实际中如果指定的锁ID不一样，是无法达到对代码进行串行调用控制的，且指定的锁ID可能会与其他不相关业务冲突，从而造成没必要的并发控制。指定的锁ID需要位于0 到的1073741823区间。

1.2.1.1 api

function request(id in integer,
                    lockmode in integer default x_mode,
                    timeout in integer default maxwait,
                    release_on_commit in boolean default FALSE)
    return integer;

1.2.1.2 实例

1.2.2 通过指定需要锁定的名称

通过锁名称申请用户锁时相对更常用，常用的场景为指定一个表名称，名称区分大小写，不能以ORA$开头，最大支持128bytes

1.2.2.1 api

    1、首先调用procedure allocate_unique(lockname in varchar2,
               lockhandle out varchar2,
               expiration_secs in integer default 864000);

获取生成的lockid (相同的lockname,在expiration_secs时间范围内生成的lockid总是相同,大小为[1073741824,1999999999])。

2、然后调用另一个重载的函数request用来通过lockid申请用户锁。

function request(lockhandle in varchar2,
                    lockmode in integer default x_mode,
                    timeout in integer default maxwait,
                    release_on_commit in boolean default FALSE)
    return integer;

1.2.2.2 实例

1.3 释放用户锁

如果在申请锁时为定义release_on_commit=true, 会话提交时也不释放此锁，此时只有会话必须显示释放，否则只能等待会话结束后由数据库自动清理自动清理，需要注意的时，最好在业务代码退出中捕获异常的代码中也显示调用释放用户锁代码。

相对于前面的两个申请方式，oracle中有两个对应的释放方法：

1.3.1 对应锁ID的释放方法

当以锁ID申请用户锁时，对应的方法为function release(id in integer) return integer; 入参为锁ID,返回值为0或4，说明释放成功。

1.3.2 对应名称的释放方法

当以名称指定申请用户锁时，对应的方法为function release(lockhandle in varchar2) return integer;，其中入参为allocate_unique过程产生的lockid。,返回值为0或4，说明释放成功。

   3 – 参数错误
  4 – 当前会话不再拥有指定的锁
  5 – 不合法的lockhandle

1.4 转换用户锁模式

如果在会话中以某种锁定模式获得锁后，如果对锁定模式升级或降级时，以应对并发度的减少或增加。则需要用到所动模式转换

相对于前面的两个申请方式，oracle中有两个对应的释放方法：

1.4.1 对应锁ID的转换方法

当以锁ID申请用户锁时，对应的方法为function convert(id in integer,
                   lockmode in integer,
                   timeout in number default maxwait)
    return integer; 入参为锁ID,新的锁定模式，最大等待时长（s）,返回值为0，说明释放成功。

1.4.2 对应名称的转换方法

当以名称指定申请用户锁时，对应的方法为function convert(lockhandle in varchar2, lockmode in integer, timeout in number default maxwait)
return integer;，其中入参为allocate_unique过程产生的lockid，新的锁定模式，最大等待时长（s）,返回值为0，说明转换成功。

3 – 参数错误
4 – 当前会话不再拥有指定的锁
5 – 不合法的lockhandle

1.5 当前会话睡眠

procedure sleep(seconds in number);入参为睡眠时长(s)，用来显示指定当前会话阻塞时长。

1.6 全局测试实例

1.6.1 准备函数

这里暂且以名称申请用户锁来作为测试例子，（以锁ID进行申函数大体类似）

1.6.1.1 创建申请锁的函数

1.6.1.2 创建转换锁的函数

1.6.1.3 创建释放锁的函数

1.6.2 测试申请、转换、睡眠、释放

1.6.2.1 测试代码

1.6.2.2 测试输出

1.6.3 测试控制代码并发调用

测试指定业务操作的并发性控制：暂以两个会话调用同一代码为例，会话1称为A，会话2称为B；

1.6.3.1 测试原则

FtpClient 种来操作FTP的上传和下载，带进度条

FtpClient 类来操作FTP的上传和下载，带进度条

先给出FtpClient 类（还没有做完。明天继续）

using System; using System.Collections.Generic; using System.Net; using System.IO; using System.Windows.Forms; namespace FTPXHC { /// <summary> /// FTP客户端操作类 /// </summary> public class FtpClient { public delegate void chpro(double sum,double size); #region 构造函数 /// <summary> /// 创建FTP工具 /// <para> /// 默认不使用SSL,使用二进制传输方式,使用被动模式 /// </para> /// </summary> /// <param name="host">主机名称</param> /// <param name="userId">用户名</param> /// <param name="password">密码</param> public FtpClient(string host, string userId, string password) : this(host, userId, password, 21, null, false, true, true) { System.Windows.Forms.Control.CheckForIllegalCrossThreadCalls = false; } //服务器上文件总大小 public long serverfilesize = 0; //已经下载了多少 public long filesize = 0; public chpro delechpro; /// <summary> /// 创建FTP工具 /// </summary> /// <param name="host">主机名称</param> /// <param name="userId">用户名</param> /// <param name="password">密码</param> /// <param name="port">端口</param> /// <param name="enableSsl">允许Ssl</param> /// <param name="proxy">代理</param> /// <param name="useBinary">允许二进制</param> /// <param name="usePassive">允许被动模式</param> public FtpClient(string host, string userId, string password, int port, IWebProxy proxy, bool enableSsl, bool useBinary, bool usePassive) { this.userId = userId; this.password = password; if (host.ToLower().StartsWith("ftp://")) { this.host = host; } else { this.host = "ftp://" + host; } this.port = port; this.proxy = proxy; this.enableSsl = enableSsl; this.useBinary = useBinary; this.usePassive = usePassive; } #endregion #region 主机 private string host = string.Empty; /// <summary> /// 主机 /// </summary> public string Host { get { return this.host ?? string.Empty; } } #endregion #region 登录用户名 private string userId = string.Empty; /// <summary> /// 登录用户名 /// </summary> public string UserId { get { return this.userId; } } #endregion #region 密码 private string password = string.Empty; /// <summary> /// 密码 /// </summary> public string Password { get { return this.password; } } #endregion #region 代理 IWebProxy proxy = null; /// <summary> /// 代理 /// </summary> public IWebProxy Proxy { get { return this.proxy; } set { this.proxy = value; } } #endregion #region 端口 private int port = 21; /// <summary> /// 端口 /// </summary> public int Port { get { return port; } set { this.port = value; } } #endregion #region 设置是否允许Ssl private bool enableSsl = false; /// <summary> /// EnableSsl /// </summary> public bool EnableSsl { get { return enableSsl; } } #endregion #region 使用被动模式 private bool usePassive = true; /// <summary> /// 被动模式 /// </summary> public bool UsePassive { get { return usePassive; } set { this.usePassive = value; } } #endregion #region 二进制方式 private bool useBinary = true; /// <summary> /// 二进制方式 /// </summary> public bool UseBinary { get { return useBinary; } set { this.useBinary = value; } } #endregion #region 远端路径 private string remotePath = "/"; /// <summary> /// 远端路径 /// <para> /// 返回FTP服务器上的当前路径(可以是 / 或 /a/../ 的形式) /// </para> /// </summary> public string RemotePath { get { return remotePath; } set { string result = "/"; if (!string.IsNullOrEmpty(value) && value != "/") { result = "/" + value.TrimStart('/').TrimEnd('/') + "/"; } this.remotePath = result; } } #endregion #region 创建一个FTP连接 /// <summary> /// 创建一个FTP请求 /// </summary> /// <param name="url">请求地址</param> /// <param name="method">请求方法</param> /// <returns>FTP请求</returns> private FtpWebRequest CreateRequest(string url, string method) { //建立连接 FtpWebRequest request = (FtpWebRequest)WebRequest.Create(url); request.Credentials = new NetworkCredential(this.userId, this.password); request.Proxy = this.proxy; request.KeepAlive = false;//命令执行完毕之后关闭连接 request.UseBinary = useBinary; request.UsePassive = usePassive; request.EnableSsl = enableSsl; request.Method = method; return request; } #endregion #region 上传一个文件到远端路径下 /// <summary> /// 把文件上传到FTP服务器的RemotePath下 /// </summary> /// <param name="localFile">本地文件信息</param> /// <param name="remoteFileName">要保存到FTP文件服务器上的名称</param> public bool Upload(FileInfo localFile, string remoteFileName) { bool result = false; if (localFile.Exists) { string url = Host.TrimEnd('/') + RemotePath + remoteFileName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.UploadFile); //上传数据 using (Stream rs = request.GetRequestStream()) using (FileStream fs = localFile.OpenRead()) { byte[] buffer = new byte[4096];//4K int count = fs.Read(buffer, 0, buffer.Length); while (count > 0) { rs.Write(buffer, 0, count); count = fs.Read(buffer, 0, buffer.Length); } fs.Close(); result = true; } return result; } throw new Exception(string.Format("本地文件不存在,文件路径:{0}", localFile.FullName)); } #endregion #region 从FTP服务器上下载文件 /// <summary> /// 从当前目录下下载文件 /// <para> /// 如果本地文件存在,则从本地文件结束的位置开始下载. /// </para> /// </summary> /// <param name="serverName">服务器上的文件名称</param> /// <param name="localName">本地文件名称</param> /// <returns>返回一个值,指示是否下载成功</returns> public bool Download(string serverName, string localName) { bool result = false; using (FileStream fs = new FileStream(localName, FileMode.OpenOrCreate)) //创建或打开本地文件 { //建立连接 string url = Host.TrimEnd('/') + RemotePath + serverName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.DownloadFile); request.ContentOffset = fs.Length; filesize = fs.Length; using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { fs.Position = fs.Length; byte[] buffer = new byte[1024 * 1024];//4K serverfilesize = GetFileSize(serverName); int count = response.GetResponseStream().Read(buffer, 0, buffer.Length); while (count > 0) { fs.Write(buffer, 0, count); filesize += count; delechpro(Convert.ToDouble(serverfilesize), Convert.ToDouble(filesize)); count = response.GetResponseStream().Read(buffer, 0, buffer.Length); } response.GetResponseStream().Close(); } result = true; } return result; } #endregion #region 重命名FTP服务器上的文件 /// <summary> /// 文件更名 /// </summary> /// <param name="oldFileName">原文件名</param> /// <param name="newFileName">新文件名</param> /// <returns>返回一个值,指示更名是否成功</returns> public bool Rename(string oldFileName, string newFileName) { bool result = false; //建立连接 string url = Host.TrimEnd('/') + RemotePath + oldFileName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.Rename); request.RenameTo = newFileName; using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { result = true; } return result; } #endregion #region 从当前目录下获取文件列表 /// <summary> /// 获取当前目录下文件列表 /// </summary> /// <returns></returns> public List<string> GetFileList() { List<string> result = new List<string>(); //建立连接 string url = Host.TrimEnd('/') + RemotePath; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.ListDirectory); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.Default);//中文文件名 string line = reader.ReadLine(); while (line != null) { result.Add(line); line = reader.ReadLine(); } } return result; } #endregion #region 从FTP服务器上获取文件和文件夹列表 /// <summary> /// 获取详细列表 /// </summary> /// <returns></returns> public List<string> GetFileDetails() { List<string> result = new List<string>(); //建立连接 string url = Host.TrimEnd('/') + RemotePath; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.ListDirectoryDetails); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { StreamReader reader = new StreamReader(response.GetResponseStream(), System.Text.Encoding.Default);//中文文件名 string line = reader.ReadLine(); while (line != null) { result.Add(line); line = reader.ReadLine(); } } return result; } #endregion #region 从FTP服务器上删除文件 /// <summary> /// 删除FTP服务器上的文件 /// </summary> /// <param name="fileName">文件名称</param> /// <returns>返回一个值,指示是否删除成功</returns> public bool DeleteFile(string fileName) { bool result = false; //建立连接 string url = Host.TrimEnd('/') + RemotePath + fileName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.DeleteFile); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { result = true; } return result; } #endregion #region 在FTP服务器上创建目录 /// <summary> /// 在当前目录下创建文件夹 /// </summary> /// <param name="dirName">文件夹名称</param> /// <returns>返回一个值,指示是否创建成功</returns> public bool MakeDirectory(string dirName) { bool result = false; //建立连接 string url = Host.TrimEnd('/') + RemotePath + dirName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.MakeDirectory); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { result = true; } return result; } #endregion #region 从FTP服务器上删除目录 /// <summary> /// 删除文件夹 /// </summary> /// <param name="dirName">文件夹名称</param> /// <returns>返回一个值,指示是否删除成功</returns> public bool DeleteDirectory(string dirName) { bool result = false; //建立连接 string url = Host.TrimEnd('/') + RemotePath + dirName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.RemoveDirectory); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { result = true; } return result; } #endregion #region 从FTP服务器上获取文件大小 /// <summary> /// 获取文件大小 /// </summary> /// <param name="fileName"></param> /// <returns></returns> public long GetFileSize(string fileName) { long result = 0; //建立连接 string url = Host.TrimEnd('/') + RemotePath + fileName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.GetFileSize); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { result = response.ContentLength; } return result; } #endregion #region 给FTP服务器上的文件追加内容 /// <summary> /// 给FTP服务器上的文件追加内容 /// </summary> /// <param name="localFile">本地文件</param> /// <param name="remoteFileName">FTP服务器上的文件</param> /// <returns>返回一个值,指示是否追加成功</returns> public bool Append(FileInfo localFile, string remoteFileName) { if (localFile.Exists) { using (FileStream fs = new FileStream(localFile.FullName, FileMode.Open)) { return Append(fs, remoteFileName); } } throw new Exception(string.Format("本地文件不存在,文件路径:{0}", localFile.FullName)); } /// <summary> /// 给FTP服务器上的文件追加内容 /// </summary> /// <param name="stream">数据流(可通过设置偏移来实现从特定位置开始上传)</param> /// <param name="remoteFileName">FTP服务器上的文件</param> /// <returns>返回一个值,指示是否追加成功</returns> public bool Append(Stream stream, string remoteFileName) { bool result = false; if (stream != null && stream.CanRead) { //建立连接 string url = Host.TrimEnd('/') + RemotePath + remoteFileName; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.AppendFile); using (Stream rs = request.GetRequestStream()) { //上传数据 byte[] buffer = new byte[4096];//4K int count = stream.Read(buffer, 0, buffer.Length); while (count > 0) { rs.Write(buffer, 0, count); count = stream.Read(buffer, 0, buffer.Length); } result = true; } } return result; } #endregion #region 获取FTP服务器上的当前路径 /// <summary> /// 获取FTP服务器上的当前路径 /// </summary> public string CurrentDirectory { get { string result = string.Empty; string url = Host.TrimEnd('/') + RemotePath; FtpWebRequest request = CreateRequest(url, WebRequestMethods.Ftp.PrintWorkingDirectory); using (FtpWebResponse response = (FtpWebResponse)request.GetResponse()) { string temp = response.StatusDescription; int start = temp.IndexOf('"') + 1; int end = temp.LastIndexOf('"'); if (end >= start) { result = temp.Substring(start, end - start); } } return result; } } #endregion #region 检查当前路径上是否存在某个文件 /// <summary> /// 检查文件是否存在 /// </summary> /// <param name="fileName">要检查的文件名</param> /// <returns>返回一个值,指示要检查的文件是否存在</returns> public bool CheckFileExist(string fileName) { bool result = false; if (fileName != null && fileName.Trim().Length > 0) { fileName = fileName.Trim(); List<string> files = GetFileList(); if (files != null && files.Count > 0) { foreach (string file in files) { if (file.ToLower() == fileName.ToLower()) { result = true; break; } } } } return result; } #endregion } } /* FTP全状态码查询词典 1xx - 肯定的初步答复 这些状态代码指示一项操作已经成功开始，但客户端希望在继续操作新命令前得到另一个答复。 • 110 重新启动标记答复。 • 120 服务已就绪，在 nnn 分钟后开始。 • 125 数据连接已打开，正在开始传输。 • 150 文件状态正常，准备打开数据连接。 2xx - 肯定的完成答复 一项操作已经成功完成。客户端可以执行新命令。 • 200 命令确定。 • 202 未执行命令，站点上的命令过多。 • 211 系统状态，或系统帮助答复。 • 212 目录状态。 • 213 文件状态。 • 214 帮助消息。 • 215 NAME 系统类型，其中，NAME 是 Assigned Numbers 文档中所列的正式系统名称。 • 220 服务就绪，可以执行新用户的请求。 • 221 服务关闭控制连接。如果适当，请注销。 • 225 数据连接打开，没有进行中的传输。 • 226 关闭数据连接。请求的文件操作已成功（例如，传输文件或放弃文件）。 • 227 进入被动模式 (h1,h2,h3,h4,p1,p2)。 • 230 用户已登录，继续进行。 • 250 请求的文件操作正确，已完成。 • 257 已创建“PATHNAME”。 3xx - 肯定的中间答复 该命令已成功，但服务器需要更多来自客户端的信息以完成对请求的处理。 • 331 用户名正确，需要密码。 • 332 需要登录帐户。 • 350 请求的文件操作正在等待进一步的信息。 4xx - 瞬态否定的完成答复 该命令不成功，但错误是暂时的。如果客户端重试命令，可能会执行成功。 • 421 服务不可用，正在关闭控制连接。如果服务确定它必须关闭，将向任何命令发送这一应答。 • 425 无法打开数据连接。 • 426 Connection closed; transfer aborted. • 450 未执行请求的文件操作。文件不可用（例如，文件繁忙）。 • 451 请求的操作异常终止：正在处理本地错误。 • 452 未执行请求的操作。系统存储空间不够。 5xx - 永久性否定的完成答复 该命令不成功，错误是永久性的。如果客户端重试命令，将再次出现同样的错误。 • 500 语法错误，命令无法识别。这可能包括诸如命令行太长之类的错误。 • 501 在参数中有语法错误。 • 502 未执行命令。 • 503 错误的命令序列。 • 504 未执行该参数的命令。 • 530 未登录。 • 532 存储文件需要帐户。 • 550 未执行请求的操作。文件不可用（例如，未找到文件，没有访问权限）。 • 551 请求的操作异常终止：未知的页面类型。 • 552 请求的文件操作异常终止：超出存储分配（对于当前目录或数据集）。 • 553 未执行请求的操作。不允许的文件名。 常见的 FTP 状态代码及其原因 • 150 - FTP 使用两个端口：21 用于发送命令，20 用于发送数据。状态代码 150 表示服务器准备在端口 20 上打开新连接，发送一些数据。 • 226 - 命令在端口 20 上打开数据连接以执行操作，如传输文件。该操作成功完成，数据连接已关闭。 • 230 - 客户端发送正确的密码后，显示该状态代码。它表示用户已成功登录。 • 331 - 客户端发送用户名后，显示该状态代码。无论所提供的用户名是否为系统中的有效帐户，都将显示该状态代码。 • 426 - 命令打开数据连接以执行操作，但该操作已被取消，数据连接已关闭。 • 530 - 该状态代码表示用户无法登录，因为用户名和密码组合无效。如果使用某个用户帐户登录，可能键入错误的用户名或密码，也可能选择只允许匿名访问。如果使用匿名帐户登录，IIS 的配置可能拒绝匿名访问。 • 550 - 命令未被执行，因为指定的文件不可用。例如，要 GET 的文件并不存在，或试图将文件 PUT 到您没有写入权限的目录。 */

再看界面调用这个类

using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Text; using System.Windows.Forms; using System.Net; using FTPXHC; using System.Threading; namespace ftp { public partial class Form1 : Form { public Form1() { InitializeComponent(); } //定义一个线程 Thread th = null; private void button1_Click(object sender, EventArgs e) { #region 下载 progressBar1.Minimum = 0; progressBar1.Maximum = 10000; progressBar1.Value = 0; th = new Thread(new ThreadStart(getth)); th.IsBackground = true; th.Start(); //计数器主要是为了计算下载速度 timer1.Tick += new EventHandler(timer1_Tick); timer1.Interval = 1000; timer1.Start(); #endregion } #region 计算下载速度 //计算文件大小差 double lastsize = 0;//最后一次文件大小 double firstsize = 0;//上一次文件大小 void timer1_Tick(object sender, EventArgs e) { double xxx = (lastsize - firstsize) / 1024.0; if (xxx >= 1024) { label2.Text = (xxx / 1024.0).ToString("0.00") + "MB/S"; } else { label2.Text = xxx.ToString("0.00") + "KB/S"; } firstsize = lastsize; } #endregion #region 进度步比例对算后的值 double getprogressBarint(double sum, double num) { double x = sum / 10000; double barint = 0; barint = num / x; return barint; } #endregion void getth() { string path = "文件名称"; FtpClient fc = new FtpClient(ftp://xxxxxxxx, "用户名", "密码"); fc.RemotePath = "/bak/bak/"; fc.delechpro = ch; if (fc.Download(path, @"D:\" + path)) { progressBar1.Value = progressBar1.Maximum; timer1.Stop(); th.Abort(); } } #region 用委托方法时刻得到进度条的值 void ch(double sum, double filesize) { lastsize = filesize; double getint = getprogressBarint(sum, filesize); int print = Convert.ToInt16(getint); if (print >= progressBar1.Maximum || sum == filesize) { progressBar1.Value = progressBar1.Maximum; } else { progressBar1.Value = print; label1.Text = (filesize / sum).ToString("0.00%"); } } #endregion } }

锁定模式	说明	TM锁中的模式
nl_mode	nl锁定模式	Null	并发度从上到下依次减小
ss_mode	subshared锁定模式	row share(RS)
sx_mode	subexclusive锁定模式	row exclusive(RX)
s_mode	shared锁定模式	share mode (S)
ssx_mode	subshared exclusive锁定模式	share row exclusive mode(SRX)
x_mode	exclusive锁定模式	exclusive mode (X)

关系	其他会话试图以某种锁定模式获取会话1所申请的用户锁时
NL	SS	SX	S	SSX	X
会话1以某种锁定模锁定	NL	SUCC	SUCC	SUCC	SUCC	SUCC	SUCC
SS	SUCC	SUCC	SUCC	SUCC	SUCC	fail
SX	SUCC	SUCC	SUCC	fail	fail	fail
S	SUCC	SUCC	fail	SUCC	fail	fail
SSX	SUCC	SUCC	fail	fail	fail	fail
X	SUCC	fail	fail	fail	fail	fail

1 使用dbms_lock包控制串行