package mysqlconnection;
import java.sql.*;
public class sql_data
{
String sDBDriver="com.mysql.jdbc.Driver";
String sConnStr="jdbc:mysql://localhost/data?user=dbuser&password=11234&useUnicode=true&characterEncoding=gb2312";
Connection conn=null;
ResultSet rs=null;
public sql_data()
{
try
{
Class.forName(sDBDriver);
}
catch(java.lang.ClassNotFoundException e)
{
System.err.println("sql_data():"+e.getMessage());
}
}
public void Insert(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Insert:"+ex.getMessage());
}
}
public void Update(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Update:"+ex.getMessage());
}
}
public ResultSet Query(String sql)
{
rs=null;
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
rs=stmt.executeQuery(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Query:"+ex.getMessage());
}
return rs;
}
public void Delete(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Delete:"+ex.getMessage());
}
}
}
import java.sql.*;
public class sql_data
{
String sDBDriver="com.mysql.jdbc.Driver";
String sConnStr="jdbc:mysql://localhost/data?user=dbuser&password=11234&useUnicode=true&characterEncoding=gb2312";
Connection conn=null;
ResultSet rs=null;
public sql_data()
{
try
{
Class.forName(sDBDriver);
}
catch(java.lang.ClassNotFoundException e)
{
System.err.println("sql_data():"+e.getMessage());
}
}
public void Insert(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Insert:"+ex.getMessage());
}
}
public void Update(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Update:"+ex.getMessage());
}
}
public ResultSet Query(String sql)
{
rs=null;
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
rs=stmt.executeQuery(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Query:"+ex.getMessage());
}
return rs;
}
public void Delete(String sql)
{
try
{
conn=DriverManager.getConnection(sConnStr);
Statement stmt=conn.createStatement();
stmt.executeUpdate(sql);
}
catch(SQLException ex)
{
System.err.println("sql_data.Delete:"+ex.getMessage());
}
}
}
解决方案 »
- JDK有免安装?
- java时间段重复,交错判断方法,急,在线等!!
- Struts2使用convention或codebehind零配置,action还可以用spring管理吗
- java jsp 中有没有类似dbgrid 控件
- GIS 到底是什么
- 朝java web方向发展学些什么?
- 异构系统之间的单点登陆sso?
- jboss服务报错 求救!!!!!!!!!!!!!
- 关于JDBC(please help!)
- 谁有JPad Pro4.3注册码?
- jsp能否传一个查询参数给chm文件,然后chm文件自动打开, 并显示相应查询的内容?(chm文件已做好)
- SmartUpload上传提示这样的错误cannot access upload.SmartUpload?
String url ="jdbc:mysql://127.0.0.1/fly?user= &password= &useUnicode=true&characterEncoding=gb2312";
Connection conn= DriverManager.getConnection(url);
private String sDBDriver="org.gjt.mm.mysql.Driver";
private String sConnStr="jdbc:mysql://localhost/lib?user=lib&password=lib&useUnicode=true&characterEncoding=ISO-8859-1";
private Connection conn=null;
private ResultSet rs=null;
private Statement stmt=null; public DBconn(){
}
public String getsConnStr(){
return sConnStr;
} public void setsConnStr(String sConnStr){
this.sConnStr=sConnStr;
} public boolean openConnection(){
try{
Class.forName(sDBDriver);
}
catch(java.lang.ClassNotFoundException e){
System.out.println("DBconn():"+e.getMessage());
return false;
}
try{
this.conn = DriverManager.getConnection(sConnStr);
}catch(SQLException e){
System.out.println("生成Connection过程中出现错误:"+e.getMessage());
return false;
}
return true;
} public void executeUpdate(String query)throws Exception{
query=new String(query.getBytes("GBK"),"ISO8859_1"); this.stmt=conn.createStatement();
stmt.executeUpdate(query);
if(stmt!=null) stmt.close();
}
public ResultSet executeQuery(String query)throws Exception{
query=new String(query.getBytes("GBK"),"ISO8859_1");
this.stmt=conn.createStatement();
this.rs=stmt.executeQuery(query);
return rs;
}
public int getColumnCount() throws SQLException{
ResultSetMetaData rsmd =rs.getMetaData();
return rsmd.getColumnCount();
}
public String getColumnName(int index) throws SQLException{
ResultSetMetaData rsmd =rs.getMetaData();
return rsmd.getColumnName(index);
}
public String getData(int index) throws SQLException{
return rs.getString(index).trim();
}
public String getData(String columnName) throws SQLException{
return rs.getString(columnName).trim();
}
public boolean next() throws SQLException{
return rs.next();
}
public void close() throws SQLException{
if(conn!=null) conn.close();
if(rs!=null) rs.close();
if(stmt!=null) stmt.close();
}
public void finalize() throws Throwable{
this.close();
}
}