相关软件和驱动:
mysql下载版本:4.1.11
http://dev.mysql.com/downloads/mysql/4.1.html
JDBC驱动下载版本:3.1.8
http://dev.mysql.com/downloads/connector/j/3.1.html
复制代码代码如下:
代码
Actipro CodeHighlighter(フリーウェア)http://www.codehighlighter.com/--> Import java.sql。*;
パブリッククラスmysql {
public static string url = "jdbc:mysql:// localhost:3306/test"; // charaterencoding = gbk
public static string username = "root";
public static string password = "root";
public static Connection Con;
public staticステートメントstmt;
public static resultset Rs;
public static void main(string [] args)はsqlexceptionをスローします{
接続する();
手術();
stmt.close();
con.close();
}
public static void test(){
string sql_select = "select * from tablename where id = 1";
string sql_insert = "tablename(col1、col2 ..)値に挿入( '1'、 '2' ...)";
string sql_update = "update tablename set colname = 'update' where id = 1";
// INSERT(SQL_INSERT);
// select(sql_select);
// update(sql_update);
}
public static void connect(){
//定位驱动
試す {
class.forname( "com.mysql.jdbc.driver");
system.out.println( "加载驱动成功!");
} catch(classNotFoundException e){
system.out.println( "加载驱动失败!");
e.printstacktrace();
}
//建立连接
試す {
con = drivermanager.getConnection(url、username、password);
stmt = con.createstatement();
system.out.println( "数据库连接成功!");
} catch(sqlexception e){
system.out.println( "数据库连接失败!");
}
}
public static void select(string sql){
試す {
rs = stmt.executequery(sql);
resultsetmetadata meta_data = rs.getmetadata(); //列名
for(int i_col = 1; i_col <= meta_data.getColumncount(); i_col ++){
System.out.print(meta_data.getColumnLabel(i_col) + "");
}
System.out.println();
while(rs.next()){
for(int i_col = 1; i_col <= meta_data.getColumncount(); i_col ++){
System.out.print(rs.getString(i_col) + "");
}
System.out.println();
}
rs.close();
} catch(例外e){
system.out.println( "数据查询失败!");
}
}
public static void insert(string sql){
試す {
stmt.clearbatch();
stmt.addbatch(sql);
stmt.executeBatch();
system.out.println( "数据插入成功!");
} catch(例外e){
system.out.println( "数据插入失败!");
}
}
public static void update(string sql){
試す {
stmt.executeupdate(sql);
system.out.println( "数据更新成功!");
} catch(例外e){
system.out.println( "数据更新失败!");
}
}
}