擅长:python、mysql、java
<p>您可能只需要实例变量:</p>
<pre><code>class Message():
def __init__(self):
self.insertStatement= ''
self.insertCounter = 0
def Save(self, msg)
if msg.topic.startswith("topic1/"):
self.insertStatement += "INSERT INTO mydatabase.table VALUES (" + msg.payload.decode("utf-8") + "," + datetime + ");"
elif msg.topic.startswith("topic2/"):
self.insertStatement += "INSERT INTO mydatabase.table1 VALUES (" + msg.payload.decode("utf-8") + "," + datetime + ");"
elif msg.topic.startswith("topic3/")
self.insertStatement += "INSERT INTO mydatabase.table2 VALUES (" +msg.payload.decode("utf-8") + "," + datetime + ");"
elif msg.topic.startswith("messages"):
self.insertStatement += "INSERT INTO mydatabase.table3 VALUES ('" + msg.topic + "'," + msg.payload.decode("utf-8") + "," + datetime + ");"
else:
return
self.insertcounter += 1
if self.insertCounter > 1000:
# do the SQL thing
</code></pre>
<p>作为一个程序员,你应该非常,非常,<strong>非常</strong>努力不使用全局变量。在</p>