
用这个类吧好的话,给我加加分
import javasql;
/
@功能: 一个JDBC的本地化API连接类,封装了数据 *** 作方法,只用传一个SQL语句即可
@作者: 李开欢
@日期: 2007/
/
public class ConnectionDemo {
/
这里可以将常量全部放入另一个类中,以方便修改
/
private static Connection conn;
private static Statement ps;
private static ResultSet rs;
private static final String DRIVER = "commicrosoftjdbcsqlserverSQLServerDriver";
private static final String URL = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";
private static final String USER ="sa";
private static final String PASS = "sa";
public ConnectionDemo() {
// TODO Auto-generated constructor stub
ConnectionDemogetConnection();
}
public static Connection getConnection(){
Systemoutprintln("连接中");
try {
ClassforName(ConnectionDemoDRIVER);
conn = DriverManagergetConnection(ConnectionDemoURL, ConnectionDemoUSER, ConnectionDemoPASS);
Systemoutprintln("成功连接");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
eprintStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
return conn;
}
public static Statement getStatement(String sql){
Systemoutprintln("执行SQL语句中");
try {
ps = conncreateStatement(ResultSetTYPE_SCROLL_SENSITIVE, ResultSetCONCUR_UPDATABLE);
if(sqlsubstring(0, 6)equals("select")){
rs = psexecuteQuery(sql);
Systemoutprintln("执行完查询 *** 作,结果已返回ResultSet集合");
}else if(sqlsubstring(0, 6)equals("delete")){
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕删除 *** 作");
}else if(sqlsubstring(0, 6)equals("insert")){
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕增加 *** 作");
}else{
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕更新 *** 作");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
return ps;
}
public static ResultSet getResultSet(){
Systemoutprintln("查询结果为:");
return rs;
}
public static void closeConnection(){
Systemoutprintln("关闭连接中");
try {
if (rs != null) {
rsclose();
Systemoutprintln("已关闭ResultSet");
}
if (ps != null) {
psclose();
Systemoutprintln("已关闭Statement");
}
if (conn != null) {
connclose();
Systemoutprintln("已关闭Connection");
}
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
ConnectionDemogetConnection();
String sql = "delete from type where id = 1";
ConnectionDemogetStatement(sql);
String sql2 = "insert into type values(1,'教学设备')";
ConnectionDemogetStatement(sql2);
String sql1 = "select from type";
ConnectionDemogetStatement(sql1);
ResultSet rs = ConnectionDemogetResultSet();
Systemoutprintln("编号 "+"类 型");
try {
while(rsnext()){
Systemoutprint(" "+rsgetInt(1)+" ");
Systemoutprintln(rsgetString(2));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
ConnectionDemocloseConnection();
}
}
以上就是关于如何使用Java代码连接本地Mysql数据库全部的内容,包括:如何使用Java代码连接本地Mysql数据库、C++连接mysql数据库的两种方法、如何通过JDBC来访问MySql数据库数据库链接:test,数据库名:com,用户名:r等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
微信扫一扫
支付宝扫一扫
评论列表(0条)