$mysql_server_name='localhost'; //改成自己的mysql数据库服务器$mysql_username='root'; //改成自己的mysql数据库用户名$mysql_password='123456'; //改成自己的mysql数据库密码$mysql_database='Mydb'; //改成自己的mysql数据库名 $conn=mysql_connect($mysql_server_name,$mysql_username,$mysql_password) or die("error connecting") ; //连接数据库mysql_query("set names 'utf8'"); //数据库输出编码 应该与你的数据库编码保持一致.南昌网站建设公司百恒网络PHP工程师建议用UTF-8 国际标准编码.mysql_select_db($mysql_database); //打开数据库$sql ="select * from news "; //SQL语句$result = mysql_query($sql,$conn); //查询 while($row = mysql_fetch_array($result)) //输出到页面html{ echo "div style=\"height:24px; line-height:24px; font-weight:bold;\""; //排版代码 echo $row['Topic'] . ""; echo "/div"; //排版代码} conn=mysql_connect($mysql_server_name,$mysql_username,$mysql_password); //连接数据库 mysql_query("set names 'utf8'"); //数据库输出编码mysql_select_db($mysql_database); //打开数据库$sql = "insert into messageboard (Topic,Content,Enabled,Date) values ('$Topic','$Content','1','2011-01-12')";// 生成sql语句mysql_query($sql); // 执行语句后插入表mysql_close(); //关闭MySQL连接
创新互联建站专业为企业提供成都网站建设、成都做网站、成都网站设计、成都网站制作等企业网站建设、网页设计与制作、成都企业网站模板建站服务，十多年成都做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。
准备工作： mysql库的安装。
python中mysql库用的是mysql-connector，安装执行如下命令：
第一步： 连接mysql，读取数据。
通过执行sql语句，读取mysql数据。
至此，获得mysql的原始数据raw_data 。接下来对数据进行预处理，按日期进行分组聚合，然后重命名行和列名，得到dataFrame格式的数据。
第二步： 连接ES。
这步没有太多的可解释的地方，就是配置信息。
第三步： ES主键加密。
这步的目的是为了保持主键唯一性，防止重复写入。用的方法是md5加密。
第四步： 写入ES
至此，一切的准备工作都做好了，数据也有了，主键加密也做了，就开始写入了。
用main方法执行以上方法：
最后查看一下ES写的是否成功，用查询方法
如果返回以下信息，说明ES里成功插入了数据。
另外，ES删除索引的操作：
$mysql_server_name='localhost'; //改成自己的mysql数据库服务器
$mysql_username='root'; //改成自己的mysql数据库用户名
$mysql_password='123456'; //改成自己的mysql数据库密码
$mysql_database='Mydb'; //改成自己的mysql数据库名
$conn=mysql_connect($mysql_server_name,$mysql_username,$mysql_password) or die("error connecting") ; //连接数据库
mysql_query("set names 'utf8'"); //数据库输出编码 应该与你的数据库编码保持一致.南昌网站建设公司百恒网络PHP工程师建议用UTF-8 国际标准编码.
mysql_select_db($mysql_database); //打开数据库
$sql ="select * from news "; //SQL语句
$result = mysql_query($sql,$conn); //查询
while($row = mysql_fetch_array($result)) //输出到页面html
{
echo "div style=\"height:24px; line-height:24px; font-weight:bold;\""; //排版代码
echo $row['Topic'] . "br/";
echo "/div"; //排版代码
}
conn=mysql_connect($mysql_server_name,$mysql_username,$mysql_password); //连接数据库
mysql_query("set names 'utf8'"); //数据库输出编码
mysql_select_db($mysql_database); //打开数据库
$sql = "insert into messageboard (Topic,Content,Enabled,Date) values ('$Topic','$Content','1','2011-01-12')";
// 生成sql语句
mysql_query($sql); // 执行语句后插入表
mysql_close(); //关闭MySQL连接