可以參考下面的代碼:
網(wǎng)站建設(shè)哪家好,找成都創(chuàng)新互聯(lián)公司!專注于網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、微信小程序開發(fā)、集團企業(yè)網(wǎng)站建設(shè)等服務(wù)項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了新豐免費建站歡迎大家使用!
//連接數(shù)據(jù)庫服務(wù)器
$link =?mysql_connect(‘host(服務(wù)器ip地址,本地用localhost)’,'數(shù)據(jù)庫賬戶',‘?dāng)?shù)據(jù)庫密碼’);
//選擇要連接的數(shù)據(jù)庫
mysql_select_db('數(shù)據(jù)庫名字');
//執(zhí)行查詢,返回數(shù)據(jù)源
$query = mysql_query("SELECT * FROM test");
//遍歷數(shù)據(jù)源,并賦值給$r,當(dāng)沒有數(shù)據(jù)時,變成false中斷循環(huán)
while($r = mysql_fetch_array($query)){
echo $r['field_name'];//輸出字段
}
擴展資料:
mysql使用說明
1、如果是用 MySQL +?Apache,使用的又是?FreeBSD?網(wǎng)絡(luò)操作系統(tǒng)的話,安裝時候應(yīng)按注意到FreeBSD的版本問題,在 FreeBSD 的 3.0 以下版本來說,MySQL Source 內(nèi)含的 MIT-pthread 運行是正常的,但在這版本以上,必須使用 native threads,也就是加入一個 with-named-thread-libs=-lc_r 的選項。
2、如果在 COMPILE 過程中出了問題,請先檢查gcc版本是否在 2.81 版本以上,gmake 版本是否在3.75以上。
3、如果不是版本的問題,那可能是內(nèi)存不足,請使用 ./configure--with-low-memory 來加入。
4、如果要重新做configure,那么可以鍵入?rm?config.cache 和 make clean 來清除記錄。
5、把 MySQL 安裝在 /usr/local 目錄下,這是缺省值,也可以按照需要設(shè)定所安裝的目錄。
參考資料來源:百度百科-mySQL (關(guān)系型數(shù)據(jù)庫管理系統(tǒng))
讀取數(shù)據(jù)庫,首先要將數(shù)據(jù)庫的驅(qū)動包導(dǎo)入:如果是mysql數(shù)據(jù)庫,需要導(dǎo)入mysql-connector-java-5.1.27.jar,如果是oracle就需要導(dǎo)入oracle.jar包;
然后就是建立數(shù)據(jù)庫連接,使用Connection 新建連接,然后執(zhí)行你的sql語句查詢出需要的數(shù)據(jù),下面是兩個方法: 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;}
準(zhǔn)備工作: mysql庫的安裝。
python中mysql庫用的是mysql-connector,安裝執(zhí)行如下命令:
第一步: 連接mysql,讀取數(shù)據(jù)。
通過執(zhí)行sql語句,讀取mysql數(shù)據(jù)。
至此,獲得mysql的原始數(shù)據(jù)raw_data 。接下來對數(shù)據(jù)進行預(yù)處理,按日期進行分組聚合,然后重命名行和列名,得到dataFrame格式的數(shù)據(jù)。
第二步: 連接ES。
這步?jīng)]有太多的可解釋的地方,就是配置信息。
第三步: ES主鍵加密。
這步的目的是為了保持主鍵唯一性,防止重復(fù)寫入。用的方法是md5加密。
第四步: 寫入ES
至此,一切的準(zhǔn)備工作都做好了,數(shù)據(jù)也有了,主鍵加密也做了,就開始寫入了。
用main方法執(zhí)行以上方法:
最后查看一下ES寫的是否成功,用查詢方法
如果返回以下信息,說明ES里成功插入了數(shù)據(jù)。
另外,ES刪除索引的操作:
文章名稱:怎么讀取mysql的數(shù)據(jù) java讀取mysql數(shù)據(jù)
URL分享:http://www.chinadenli.net/article38/doodjpp.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供關(guān)鍵詞優(yōu)化、網(wǎng)站導(dǎo)航、微信小程序、網(wǎng)頁設(shè)計公司、全網(wǎng)營銷推廣、營銷型網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)