(c *C)
| 684 | } |
| 685 | |
| 686 | func (s *RowsEventSuite) TestRealUpdateRowsV1(c *C) { |
| 687 | s.WriteEvent( |
| 688 | mysql_proto.LogEventType_TABLE_MAP_EVENT, |
| 689 | uint16(0), |
| 690 | []byte{ |
| 691 | // table id + flags |
| 692 | 46, 0, 0, 0, 0, 0, |
| 693 | 1, 0, |
| 694 | // db name |
| 695 | 8, |
| 696 | 115, 104, 97, 114, 100, 55, 54, 54, 0, |
| 697 | // table name |
| 698 | 30, |
| 699 | 99, 97, 109, 101, 114, 97, 95, 117, 112, 108, |
| 700 | 111, 97, 100, 95, 105, 110, 100, 101, 120, 95, |
| 701 | 115, 117, 109, 109, 97, 114, 121, 95, 118, 51, 0, |
| 702 | // # cols + cols type |
| 703 | 3, |
| 704 | 3, 3, 3, |
| 705 | // metadata len + null bits |
| 706 | 0, |
| 707 | 0}) |
| 708 | |
| 709 | s.WriteEvent( |
| 710 | mysql_proto.LogEventType_UPDATE_ROWS_EVENT_V1, |
| 711 | uint16(0), |
| 712 | []byte{ |
| 713 | // table id + flags |
| 714 | 46, 0, 0, 0, 0, 0, |
| 715 | 1, 0, |
| 716 | // # cols + used cols bit maps |
| 717 | 3, |
| 718 | 255, // before image |
| 719 | 255, // after image |
| 720 | // row data |
| 721 | 248, 236, 121, 59, 3, 176, 71, 0, 0, 177, 71, 0, 0, |
| 722 | 248, 236, 121, 59, 3, 177, 71, 0, 0, 177, 71, 0, 0}) |
| 723 | |
| 724 | c.Log(s.src.Bytes()) |
| 725 | |
| 726 | event, err := s.NextEvent() |
| 727 | c.Log(err) |
| 728 | c.Assert(err, IsNil) |
| 729 | |
| 730 | context, ok := event.(*TableMapEvent) |
| 731 | c.Assert(ok, IsTrue) |
| 732 | |
| 733 | // sanity check |
| 734 | c.Check(string(context.DatabaseName()), Equals, "shard766") |
| 735 | c.Check( |
| 736 | string(context.TableName()), |
| 737 | Equals, |
| 738 | "camera_upload_index_summary_v3") |
| 739 | |
| 740 | s.parsers.SetTableContext(context) |
| 741 | |
| 742 | event, err = s.NextEvent() |
| 743 | c.Log(err) |
nothing calls this directly
no test coverage detected