From 8aea4e9018dcb24e19ef3af16c2fb4064a430045 Mon Sep 17 00:00:00 2001
From: Mahadir Ahmad <mahadir@madet.my>
Date: Sun, 9 Jan 2022 03:17:57 +0800
Subject: [PATCH] Handle NULL value for JSON data type

---
 pymysqlreplication/packet.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/pymysqlreplication/packet.py b/pymysqlreplication/packet.py
index a5a7c0fd..c6eae5d5 100644
--- a/pymysqlreplication/packet.py
+++ b/pymysqlreplication/packet.py
@@ -343,6 +343,9 @@ def unpack_int32(self, n):
 
     def read_binary_json(self, size):
         length = self.read_uint_by_size(size)
+        if length == 0:
+            # handle NULL value
+            return None
         payload = self.read(length)
         self.unread(payload)
         t = self.read_uint8()