|
4 | 4 |
|
5 | 5 | def main():
|
6 | 6 | kv_db = KeyValueDatabaseInterface(connection_string="sqlite:///proto_buf.db")
|
7 |
| - announcement = announcement_message.Annoucement() |
8 |
| - announcement.sender = "Mikey" |
9 |
| - announcement.recipients.extend(['Joey', 'Sammy']) |
10 |
| - announcement.message = "S.O.S." |
11 |
| - kv_db.insert("message1", announcement.SerializeToString()) |
12 |
| - print("Key-Value Inserted: { '%s' : '%s' }" % (kv_db.get("message1").key, kv_db.get("message1").value)) |
| 7 | + message_to_serialize = announcement_message.Annoucement() |
| 8 | + message_to_serialize.sender = "Mikey" |
| 9 | + message_to_serialize.recipients.extend(['Joey', 'Sammy']) |
| 10 | + message_to_serialize.message = "S.O.S." |
| 11 | + print("The following the printed Protbuf object:") |
| 12 | + print(message_to_serialize) |
| 13 | + |
| 14 | + print("This is how it showed up serialized:") |
| 15 | + print(message_to_serialize.SerializeToString()) |
| 16 | + |
| 17 | + print("Inserting the message...") |
| 18 | + kv_db.insert("message1", message_to_serialize) |
| 19 | + print("Retrieving the message...") |
| 20 | + serialized_message_from_db = kv_db.get("message1").value |
| 21 | + print("This is how it looks like in after it is retrieve from the database:") |
| 22 | + print(serialized_message_from_db) |
| 23 | + |
| 24 | + print("Deserializing...") |
| 25 | + deserialized_object = announcement_message.Annoucement() |
| 26 | + deserialized_object.ParseFromString(serialized_message_from_db) |
| 27 | + print("Done. This is the deserialized message from the database:") |
| 28 | + print(deserialized_object) |
13 | 29 |
|
14 | 30 |
|
15 | 31 | if __name__ == "__main__":
|
|
0 commit comments