189 8069 5689
可以参考下面的代码：
网站建设哪家好，找成都创新互联公司！专注于网页设计、网站建设、微信开发、微信小程序开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了新丰免费建站欢迎大家使用！
//连接数据库服务器
$link = mysql_connect(‘host（服务器ip地址，本地用localhost）’,'数据库账户',‘数据库密码’);
//选择要连接的数据库
mysql_select_db('数据库名字');
//执行查询，返回数据源
$query = mysql_query("SELECT * FROM test");
//遍历数据源，并赋值给$r，当没有数据时，变成false中断循环
while($r = mysql_fetch_array($query)){
echo $r['field_name'];//输出字段
}
扩展资料：
mysql使用说明
1、如果是用 MySQL + Apache，使用的又是 FreeBSD 网络操作系统的话，安装时候应按注意到FreeBSD的版本问题，在 FreeBSD 的 3.0 以下版本来说，MySQL Source 内含的 MIT-pthread 运行是正常的，但在这版本以上，必须使用 native threads，也就是加入一个 with-named-thread-libs=-lc_r 的选项。
2、如果在 COMPILE 过程中出了问题，请先检查gcc版本是否在 2.81 版本以上，gmake 版本是否在3.75以上。
3、如果不是版本的问题，那可能是内存不足，请使用 ./configure--with-low-memory 来加入。
4、如果要重新做configure，那么可以键入 rm config.cache 和 make clean 来清除记录。
5、把 MySQL 安装在 /usr/local 目录下，这是缺省值，也可以按照需要设定所安装的目录。
参考资料来源：百度百科-mySQL （关系型数据库管理系统）
读取数据库，首先要将数据库的驱动包导入：如果是mysql数据库，需要导入mysql-connector-java-5.1.27.jar，如果是oracle就需要导入oracle.jar包；
然后就是建立数据库连接，使用Connection 新建连接，然后执行你的sql语句查询出需要的数据，下面是两个方法： public PageModel findAllUser(int pageNo,int pageSize){String sql = "select * from user where user_name 'root' order by user_name" +"limit" + (pageNo - 1) * pageSize + "," + pageSize;PageModel pageModel =null;Connection conn =null;Statement stmt =null;ResultSet rs = null;try{conn = DB.getConn();stmt = conn.createStatement();rs = stmt.executeQuery(sql);List user_List = new ArrayList();while(rs.next()){User user = new User();user.setUser_name(rs.getString("user_name"));user.setUser_password(rs.getString("user_password"));user.setUser_tel(rs.getString("user_tel"));user.setUser_email(rs.getString("user_email"));user.setUser_createDate(rs.getTimestamp("user_createdate"));user_List.add(user);}//取得所有记录int totalRecords = getTotalRecords(conn);pageModel = new PageModel();pageModel.setPageSize(pageSize);pageModel.setList(user_List);pageModel.setTotalRecord(totalRecords);}catch(SQLException e){e.printStackTrace();}finally{DB.close(rs);DB.close(stmt);DB.close(conn);}return pageModel;} /** * 取得所有记录 * @param conn * @return 所有记录totalRecords */public int getTotalRecords(Connection conn){String sql = "select count(*) from user where user_name 'root' ";int totalRecords = 0;Statement stmt = null;ResultSet rs = null;try{conn = DB.getConn();stmt = conn.createStatement();rs = stmt.executeQuery(sql);if(rs.next()){totalRecords = rs.getInt(1);}}catch(SQLException e){e.printStackTrace();}finally{DB.close(rs);DB.close(stmt);DB.close(conn);}return totalRecords;}
准备工作： mysql库的安装。
python中mysql库用的是mysql-connector，安装执行如下命令：
第一步： 连接mysql，读取数据。
通过执行sql语句，读取mysql数据。
至此，获得mysql的原始数据raw_data 。接下来对数据进行预处理，按日期进行分组聚合，然后重命名行和列名，得到dataFrame格式的数据。
第二步： 连接ES。
这步没有太多的可解释的地方，就是配置信息。
第三步： ES主键加密。
这步的目的是为了保持主键唯一性，防止重复写入。用的方法是md5加密。
第四步： 写入ES
至此，一切的准备工作都做好了，数据也有了，主键加密也做了，就开始写入了。
用main方法执行以上方法：
最后查看一下ES写的是否成功，用查询方法
如果返回以下信息，说明ES里成功插入了数据。
另外，ES删除索引的操作：