java实现mysql操作类分享 java连接mysql
相关软件和驱动:
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
代码
Code highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/-->import java.sql.*;
public class mysql {
public static String url = "jdbc:mysql://localhost:3306/test";//characterEncoding=GBK
public static String username = "root";
public static String password = "root";
public static Connection con;
public static Statement stmt;
public static ResultSet rs;
public static void main(String[] args) throws SQLException {
connect();
operation();
stmt.close();
con.close();
}
public static void test() {
String sql_select = "select * from tablename where id=1";
String sql_insert = "insert into tablename (col1,col2..) values('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() {
// 定位驱动
try {
Class.forName("com.mysql.jdbc.Driver");
System.out.println("加载驱动成功!");
} catch (ClassNotFoundException e) {
System.out.println("加载驱动失败!");
e.printStackTrace();
}
// 建立连接
try {
con = DriverManager.getConnection(url, username, password);
stmt = con.createStatement();
System.out.println("数据库连接成功!");
} catch(SQLException e) {
System.out.println("数据库连接失败!");
}
}
public static void select(String sql) {
try {
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 (Exception e) {
System.out.println("数据查询失败!");
}
}
public static void insert(String sql) {
try {
stmt.clearBatch();
stmt.addBatch(sql);
stmt.executeBatch();
System.out.println("数据插入成功!");
}catch (Exception e) {
System.out.println("数据插入失败!");
}
}
public static void update(String sql) {
try {
stmt.executeUpdate(sql);
System.out.println("数据更新成功!");
}catch (Exception e) {
System.out.println("数据更新失败!");
}
}
}
您可能感兴趣的文章:
- intellij idea实现java通过JDBC连接mysql中错误解决
- Amoeba+Mysql实现读写分离+java连接amoeba
- java连接MySql和Oracle简单实现
- Java实现app接口和Socket消息传递(10)java连接MySQL实现App登录接口
- Java、JavaScript、Oracle、MySQL中实现的MD5加密算法分享
- java实现与各类型数据库(mysql,oracle,access,db2,sybase)的连接
- java代码实现JDBC连接MySql以及引用驱动程序包
- java实现MySql连接七步
- java代码实现JDBC连接MySql以及引用驱动程序包
- java/jsp/servlet连接mysql实现用户登录
- Java语句轻松实现与数据库MYSQL【本地数据库】的连接,和对数据库的增删改查操作
- 通过代理类实现java连接数据库(使用dao层操作数据)实例分享
- 01-JDBC概念--JDBC(Java Database Connectivity:Java数据库连接):使用jdbc实现Java与数据库MySQL连接
- Java表格仿mysql实现基本操作(连接,分组排序,统计等)
- java实现mysql的连接
- Java实现Mysql的jdbc连接例子
- java数据库操作类演示实例分享(java连接数据库)
- Java连接MySQL实现增删改查
- 实现Java连接mysql(源码)!