实时数据写入MySQL，一般需要结合实时数据流处理框架。常见的实时数据流处理框架包括Apache Flink、Apache Storm等。这里以Apache Flink为例介绍如何将实时数据写入MySQL。

1. 依赖

首先需要添加MySQL连接驱动的依赖，这里以MySQL Connector/J为例：

<dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

<version>8.0.23</version>

</dependency>

2. 数据源

接下来需要配置MySQL数据源。可以通过以下代码来配置：

// 建立MySQL连接

Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/sample_db", "username", "password");

// 执行SQL语句

Statement stmt = conn.createStatement();

ResultSet rs = stmt.executeQuery("SELECT * FROM sample_table");

// 处理查询结果

while (rs.next()) {

int id = rs.getInt("id");

String name = rs.getString("name");

// ...

}

// 关闭连接

rs.close();

stmt.close();

conn.close();

其中，连接地址、用户名和密码需要根据实际情况进行配置。

3. 写入MySQL

接下来是将实时数据写入MySQL的部分。Flink提供了一个叫做JDBCOutputFormat的数据源，可以将数据写入到关系型数据库。使用方法如下：

// 创建一个JDBC连接器

JDBCOutputFormat outputFormat = JDBCOutputFormat.buildJDBCOutputFormat()

.setDrivername("com.mysql.cj.jdbc.Driver")

.setDBUrl("jdbc:mysql://localhost:3306/sample_db")

.setUsername("username")

.setPassword("password")

.setQuery("INSERT INTO sample_table (id, name) VALUES (?, ?)")

.finish();

// 将数据写入MySQL

dataStream

.addSink(outputFormat)

.name("MySQL Sink");

其中，setQuery方法用于设置SQL语句，?表示占位符。在写入数据时，可以通过调用outputFormat.writeRecord方法将数据写入MySQL。

如果需要更新或删除MySQL中的数据，则可以使用以下语句：

UPDATE sample_table SET column1=value1 WHERE condition;

DELETE FROM sample_table WHERE condition;

以上是将实时数据写入MySQL的基本步骤和方法。在实际使用过程中，还需要注意数据结构和数据类型的匹配问题，以及数据量和写入速度的优化等问题。

实时数据可以通过多种方式写入MySQL数据库中：

1. 使用MySQL INSERT语句将实时数据写入数据库：

INSERT INTO table_name (column1, column2, column3, ...)

VALUES (value1, value2, value3, ...);

这种方式需要在运行时插入实时数据。可以通过编写一个脚本来不断读取实时数据并将其插入MySQL表中。

2. 使用MySQL LOAD DATA INFILE语句将实时数据批量写入数据库：

LOAD DATA INFILE 'filename.txt' INTO TABLE table_name

FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n';

这种方式适用于大量数据的批量写入。可以将实时数据写入一个包含多个数据行的文本文件中，然后使用LOAD DATA INFILE语句将它们一次性写入MySQL表中。

3. 使用MySQL TRIGGER语句将实时数据写入数据库：

CREATE TRIGGER trigger_name

AFTER INSERT ON table_name

FOR EACH ROW

BEGIN

INSERT INTO another_table (column1, column2, column3, ...)

VALUES (NEW.value1, NEW.value2, NEW.value3, ...);

END;

这种方式适用于在某些条件下自动将实时数据写入数据库。可以使用TRIGGER语句在MySQL表中创建一个触发器，在满足一定条件的情况下，自动将实时数据写入另一个表中。

无论使用哪种方式，都需要确保表的结构和数据类型与实时数据匹配，否则写入操作将失败。同时，为了保证数据安全，还需要进行合适的授权和权限管理，防止恶意攻击造成数据泄漏或损害。