可以參考下面的代碼:
網站建設哪家好,找成都創新互聯公司!專注于網頁設計、網站建設、微信開發、微信小程序開發、集團企業網站建設等服務項目。為回饋新老客戶創新互聯還提供了新豐免費建站歡迎大家使用!
//連接數據庫服務器
$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刪除索引的操作:
文章名稱:怎么讀取mysql的數據 java讀取mysql數據
URL分享:http://vcdvsql.cn/article38/doodjpp.html
成都網站建設公司_創新互聯,為您提供關鍵詞優化、網站導航、微信小程序、網頁設計公司、全網營銷推廣、營銷型網站建設
聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯