持续更新,Mysql数据库的增删改查

出处:kelvin19840813 的博客

引发思考

今天,发现开发项目中的单号重复了。

图片 1

这是多用户并发操作相同数据导致的结果。有点抽象,理解如下:实际就是多个事务交叉执行(增、删、查、改)了相同数据。导致一个事务不具有完整性了,数据库的数据也不一致了(这里‘’一致‘’可以理解为:我希望的数据,跟我想像的不一样,比如明明我刚update某表性别为男,我update完它还是女的,如果别人要修改,也得等我update完再改呀!咦,统计男生的总人数的确是加1了,见鬼了)。

图片 2

在运行程序之前需要在mysql数据库中创建test数据库,如下图所示:图片 3

您的支持是对博主最大的鼓励,感谢您的认真阅读。本文版权归作者所有,欢迎转载,但请保留该声明。

并发操作数据的不利影响

多个用户试图修改其他用户正在使用的资源时总是会产生负面影响。(这里用户可以理解成事务,用户这个词组总是在不同场合出现,例如redis客户端用户,b/s模式客户端用户,这些情况其实可以广泛理解为请求)

更新丢失:A事务里更新某些数据,A还没结束运行。这段时间,B插足一脚,也更新了那些数据,覆盖了A刚更新完的,A白更了。一段时间后,A正常结束了,A丢失了更新的数据。

脏读:B正在修改某些数据,还没结束运行。这段时间A去读那些数据,但读的不是B修改之后的,而是B修改之前的。一段时间后,B正常结束了,A读的数据还是旧数据。

不可重复读:9点钟,A在读某部分数据。9点半,B修改了那部分数据,B结束运行了。10点钟,A又回头读那部分数据,发现数据和9点钟的不一样。A读的是同一部分,却返回不一样的数据。

 幻读:9点钟A根据条件取了一个结果集看看,还没结束运行。9点半,B删除了那个结果集部分行数据,又新增了部分行数据。10点,A根据相同条件取结果集,发现新增了部分,删除了部分,刚刚是在做梦吧?

总而言之,一旦小三插足干坏事,我就完了。

下面是具体是实现程序:

 

事务锁

针对上面的问题,可以使用事务锁解决。(事务锁是一种悲观的解决方案,)

每个事务里可能涉及行数据、页数据、表数据、,这数据相等事务依赖的资源,当请求操作这些资源,可以请求不同类型的锁。
该锁可以阻止其他事务以错误方式操作该资源。 当事务不再依赖锁定的资源时,它将释放锁。

简单说,这些数据可以被上锁、上锁后,其他事务对该数据的操做就有限制了,不是你想改就能改,你想读就读。我锁是大爷,我允许,你就能操作;我若不许,你就滚出去!

 

锁粒度: SQL
Server具有多种粒度锁定,例如行粒度、表粒度、数据库粒度……

如果在较小的粒度(例如行)加锁,可以提高并发度,因为对其他事务限制范围小,只是开销较高,锁定了多少行,则需要多少锁。

比如A事务拿到了某行数据的某锁,该限制了其他事务对该行数据的操作,但是其他事务不一定要操作该行,也是就1两个事务需要操作改行,

如果在较大的粒度(例如表)加锁,则会降低并发度,因为锁定整个表限制了其他事务对表中任意部分的访问。
但开销较低,因为需要维护的锁较少。

 

锁类型:共享锁、排他锁等。锁与锁之间是可以冲突的。比如A事务拿到了某行数据的共享锁,说明A事务结束之前,该行数据都不能被其他事务修改(增、删、改),但是其他事务可以读改行数据。其他事务永远都不能拿到该行数据的排他锁,排他锁的作用是独自占据数据的增、删、改操作。

 

这篇文章不过抛转引玉罢了,官方的就很齐全了

 

  

很多人都知道mysqlbinlog 解释出来的binlog的 insert , update 是位置相反的
, 还有表字段都是@1 … @数字 , 很恶心!!!

  1 package News;
  2 
  3 import java.sql.Connection;
  4 import java.sql.DriverManager;
  5 import java.sql.ResultSet;
  6 import java.sql.Statement;
  7 import java.util.Scanner;
  8 
  9 public class News {
 10     public static void main(String[] args) {
 11         System.out.println("< < < < < < 使用ArrayList实现新闻管理系统 > > > > > >");
 12 
 13         while (true) {
 14             Scanner scanner = new Scanner(System.in);
 15             System.out
 16                     .println("1. 查询全部新闻\n2. 添加新闻\n3. 删除新闻\n4. 按标题查询新闻\n5. 按标题修改新闻 \n0.退出\n请选择功能(1,2,3,4,5,0):");
 17             int selected = scanner.nextInt();
 18 
 19             switch (selected) {
 20             case 1:
 21                 reads();
 22                 break;
 23 
 24             case 2:
 25                 System.out.println("请输入新闻标题:");
 26                 String title = scanner.next();
 27                 System.out.println("请输入新闻内容:");
 28                 String content = scanner.next();
 29                 System.out.println("请输入新闻备注:");
 30                 String remark = scanner.next();
 31 
 32                 add(title, content,remark);
 33                 break;
 34 
 35             case 3:
 36                 System.out.println("请输入新闻标题:");
 37                 String title2 = scanner.next();
 38                 delete(title2);
 39                 break;
 40 
 41             case 4:
 42                 System.out.println("请输入新闻标题:");
 43                 String title1 = scanner.next();
 44                 read(title1);
 45                 break;
 46 
 47             case 5:
 48                 System.out.println("请输入新闻标题:");
 49                 String title3 = scanner.next();
 50                 update(title3);
 51                 break;
 52 
 53             case 0:
 54                 scanner.close();
 55                 System.exit(0);
 56                 break;
 57 
 58             default:
 59                 System.out.println("输入错误,请重新输入:");
 60                 break;
 61             }
 62         }
 63     }
 64 
 65     /**
 66      * 定义添加新闻方法
 67      * 
 68      * @param title
 69      *            标题
 70      * @param content
 71      *            内容
 72      */
 73     public static void add(String title, String content,String remark) {
 74         try {
 75             Class.forName("com.mysql.jdbc.Driver");
 76             String url = "jdbc:mysql://localhost:3306/test";
 77             String user = "root";
 78             String password = "root";
 79             Connection conn = DriverManager.getConnection(url, user, password);
 80             Statement st = conn.createStatement();
 81             String sql = "insert into news values(null,'" + title + "','"
 82                     + content + "','"+ remark + "')";
 83             int row = st.executeUpdate(sql);
 84             System.out.println(row > 0 ? "添加成功" : "添加失败");
 85         } catch (Exception e) {
 86             e.printStackTrace();
 87         }
 88     }
 89 
 90     /**
 91      * 定义查询全部方法
 92      */
 93     public static void reads() {
 94         try {
 95             Class.forName("com.mysql.jdbc.Driver");
 96             String url = "jdbc:mysql://localhost:3306/test";
 97             String user = "root";
 98             String password = "root";
 99             Connection conn = DriverManager.getConnection(url, user, password);
100             Statement st = conn.createStatement();
101             String sql = "select * from news";
102             ResultSet list = st.executeQuery(sql);
103             if (list != null) {
104                 while (list.next()) {
105                     int id = list.getInt(1);
106                     String title = list.getString(2);
107                     String content = list.getString(3);
108                     String remark = list.getString(4);
109                     System.out.println(id + "\t" + title + "\t" + content
110                             + "\t" + remark);
111                 }
112             }
113         } catch (Exception e) {
114             e.printStackTrace();
115         }
116     }
117 
118     /**
119      * 定义根据标题查询新闻的方法
120      * 
121      * @param title1
122      *            新闻标题
123      */
124     public static void read(String title1) {
125         try {
126             Class.forName("com.mysql.jdbc.Driver");
127             String url = "jdbc:mysql://localhost/test";
128             String user = "root";
129             String password = "root";
130             Connection conn = DriverManager.getConnection(url, user, password);
131             Statement st = conn.createStatement();
132             String sql = "select * from news where title='" + title1 + "'";
133             ResultSet row = st.executeQuery(sql);
134             if (row.next()) {
135                 int id = row.getInt(1);
136                 String title = row.getString(2);
137                 String content = row.getString(3);
138                 String remark = row.getString(4);
139                 System.out.println(id + "\t" + title + "\t" + content + "\t"
140                         + remark);
141             }
142         } catch (Exception e) {
143             e.printStackTrace();
144         }
145     }
146 
147     /**
148      * 定义按标题删除新闻的方法
149      * 
150      * @param title
151      *            新闻方法
152      */
153     public static void delete(String title) {
154         try {
155             Class.forName("com.mysql.jdbc.Driver");
156             String url = "jdbc:mysql://localhost:3306/test";
157             String user = "root";
158             String password = "root";
159             Connection conn = DriverManager.getConnection(url, user, password);
160             Statement st = conn.createStatement();
161             String sql = "delete from news where title='" + title + "'";
162             int row = st.executeUpdate(sql);
163             System.out.println(row > 0 ? "删除成功" : "删除失败");
164         } catch (Exception e) {
165             e.printStackTrace();
166         }
167     }
168 
169     /**
170      * 定义根据标题修改新闻的方法
171      * 
172      * @param title
173      *            新闻标题
174      */
175     public static void update(String title) {
176 
177         try {
178             Class.forName("com.mysql.jdbc.Driver");
179             String url = "jdbc:mysql://localhost:3306/test";
180             String user = "root";
181             String password = "root";
182             Connection conn = DriverManager.getConnection(url, user, password);
183             Statement st = conn.createStatement();
184             String sql = "select * from news where title='" + title + "'";
185             ResultSet list = st.executeQuery(sql);
186             if (list.next()) {
187                 Scanner sca = new Scanner(System.in);
188                 System.out.println("请输入新的新闻标题:");
189                 String title4 = sca.next();
190                 System.out.println("请输入新闻内容:");
191                 String content = sca.next();
192                 System.out.println("请输入备注:");
193                 String remark = sca.next();
194                 
195                 String sql1 = "update news set title='" + title4
196                         + "',content='" + content + "',remark='" + remark + "' where title='"+title+"'";
197                 System.out.println(sql1);
198                 int u = st.executeUpdate(sql1);
199                 System.out.println(u > 0 ? "修改成功" : "修改失败");
200                 sca.close();
201             }
202         } catch (Exception e) {
203             e.printStackTrace();
204         }
205     }
206 }

但没看到有人在 mysql8.0 功能需求时提问题出来 , 自己也没有提出来 

 

唯有自己解释 frm 文件,获取表字段名称,字段出来,
然后对应一下贴贴贴上去翻译出binlog的sql语句咯 ,并不是高深东西 ,
仅此日记记录

图片 4

0000 ~ 0001: FE 01 识别是否frm文件 , 固定

0002: 0A 是mysql版本识别位置table.cc 的 FRM_VER+3+
MY_TEST(create_info->varchar);  为6是5.0+版本mysql , 9 或者
10是有varchar的frm文件

0003: 0C 影射枚举值从 handler.h文件中 legacy_db_type , 0C 是 12
刚刚好是innodb类型 ,如下:

enum legacy_db_type
{
DB_TYPE_UNKNOWN=0,DB_TYPE_DIAB_ISAM=1,

……, DB_TYPE_INNODB,
……
};

0004 ~ 0005: 03 00 , 反着看 00 30  mysql 5.0+ 总是为3
,如果不是3,那就算了…..

0006 ~ 0007: 00 10 , 反着看 10 00  IO_SIZE: 4096

0008 ~ 0009: 01 00 暂时不知道是什么 

000a ~ 000d: 00 40 00 00 暂时不知道是什么 

000e ~ 000f: F9
16 tmp_key_length;如果等于0xffff然后密钥长度是4字节整数偏移0x002f

0010 ~ 0011: 18 08 rec_length ;这是一个默认值存储字符串的字节

0012 ~ 0015: 00 00 00 00 是 create table 语句的 MAX_ROWS 选项

0016 ~ 0019: 00 00 00 00 是 create table 语句的 min_rows 选项 ,
在 handler.h 文件

 

typedef struct st_ha_create_information
{

…….

ulonglong max_rows,min_rows;

…}

网站地图xml地图