java操作mysql的小程序（微信小程序調用mysql）

本文目錄一覽：

• 1、想用java編一個小程序可以實現mysql跟hbase的轉換，需要看些什麼書好呢？
• 2、怎樣使我的Java小程序使用MySQL
• 3、如何在Java程序中訪問mysql數據庫中的數據並進行簡單的操作
• 4、如何使用Java訪問MySQL數據庫

想用java編一個小程序可以實現mysql跟hbase的轉換，需要看些什麼書好呢？

為啥要看書捏，你需要了解hbase 的原理和存儲方式以及設計方式，剩下的就是把mysql的數據導出為文件，然後上傳到hdfs上，讀取文件，將內容寫入hbase，當然這只是其中一種方式，你還可以：

1、寫mapreduce 直接讀取mysql數據寫入hbase

2、用hive將hbase 關聯，將mysql的數據SYNC到hive中，在hbase中也就存在了。（SYNC是一個同步工具）

怎樣使我的Java小程序使用MySQL

                        JDBC    

加載JDBC驅動

與數據庫建立連接

發送SQL語句，並得到返回結果

處理返回結果

                       MyBatis

使用MyBatis SQL映射語句

                    Hibernate

Hibernate與數據庫的關聯只需要在XML中配置即可

如何在Java程序中訪問mysql數據庫中的數據並進行簡單的操作

import java.sql.*;

public class DBManager{

static Connection conn=null;

static{

System.out.println(“in DBManager”);

String dbName=”ccrs”;

try{

Class.forName(“com.mysql.jdbc.Driver”);

//配置數據源

String url=”jdbc:mysql://192.168.1.2/”+ dbName +

“?useUnicode=truecharacterEncoding=GB2312”;

conn=DriverManager.getConnection(url,”root”,”admin”);

}catch(Exception e){

System.out.println(“Exception:”+e.getMessage());

}

}

public synchronized static Connection getConnection(){

Connection temp=null;

if(conn!=null){

temp=conn;

conn=null;

return temp;

}else{

return null;

}

}

public synchronized static void releaseConnection(Connection con){

conn=con;

}

public static void closeConn(){

try{

conn.close();

}catch(SQLException e){

System.out.println(e.getMessage());

}

}

}

你要注意的地方:dbName為數據庫名，你的mysql裏面的數據庫叫什麼,這個就為什麼,例如String dbName=”yourDataBaseName”;

Class.forName(“com.mysql.jdbc.Driver”),這個就是你下的那個jar包,驅動

url=”jdbc:mysql://localhost/”+ dbName +

“?useUnicode=truecharacterEncoding=GB2312”; //localhost數據庫的機器名

conn=DriverManager.getConnection(url,”root”,”admin”);

root是你數據庫的用戶名,admin為密碼,你看你自己的數據庫的用戶名密碼為多少,這裡就為多少.

應該夠詳細了,還要注意的是你的驅動,即那個jar包你要放好,如果用eclipse的話導入你的工程屬性里.不然的話加入classpath.你不是jsp,所以不用放進你的lib里.

如何使用Java訪問MySQL數據庫

第1步 獲取Java與MySQL的連接器

第2步 將下載的包存放在自己機器上jdk安裝目錄下面的jre目錄下面的lib目錄下面的ext目錄中，在程序中導入與數據庫操作相關的對象

import java.sql.Connection; //導入數據庫連接對象

import java.sql.DriverManager; //導入數據庫驅動管理對象

import java.sql.ResultSet; //導入數據記錄集對象

import java.sql.SQLException; //導入數據SQL操作異常對象

import java.sql.Statement; //導入SQL操作接口對象

第3步：在程序中寫入如下內容

String url; //連接數據庫的字符串

String sql; //執行數據sql查詢操作的字符串

Connection conn; //數據庫連接變量

Statement st; //數據庫操作對象

ResultSet rs; //數據記錄集對象

url = “jdbc:mysql://localhost:3306/test?user=rootpassword=”; //在程序中只要修改這句，就可以實現數據庫連接

try {

conn = DriverManager.getConnection(url);

st = conn.createStatement();

sql = “select * from test”; //只要修改這句，就可以實現各種查詢操作

rs=st.executeQuery(sql); //執行數據查詢

while(rs.next())

{

System.out.println(rs.getString(1)); //獲得數據表test中第1個字段的數據，該字段為字符串類型

System.out.println(rs.getString(2)); //獲得數據表test中第2個字段的數據，該字段為字符串類型

}

rs.close(); //關閉數據記錄集

conn.close(); //關閉數據庫連接

} catch (SQLException e) {

System.out.println(“Error:”+e.toString()+e.getMessage());

}