import javasqlConnection;
import javasqlDriverManager;
import javasqlSQLException;
import javasqlStatement;
public class TestDB {
public static void main(String[] args) {
try {
// 1注册驱动
ClassforName("commicrosoftsqlserverjdbcSQLServerDriver");
Systemoutprintln("注册驱动成功");
String url = ""jdbc:microsoftsqlserver://127001:1433;DatabaseName="; //数据库IP,端口,数据库名
String username = "";
String password = "";
// 加载驱动并获取数据库连接对象
Connection connection = DriverManagergetConnection(url, username,
password);
Systemoutprintln("连接数据库成功!");
// 创建Statement对象
Statement stmt = connectioncreateStatement();
// SQL语句
String sql = "insert into student(id,name,age,email,address) values(1,'tom',23,'dfg@163com','England') ";
int rows = stmtexecuteUpdate(sql);
if (rows > 0) {
Systemoutprintln("插入成功!");
}
// 释放资源
stmtclose();
connectionclose();
} catch (SQLException e) {
eprintStackTrace();
}
catch (ClassNotFoundException e) {
eprintStackTrace();
}
}
}
预编译的数据库处理
public class ConnectionManager{
public static final String DRIVER_CLASS ="";
public static final String URL = "";
public static final String USERNAME = "";
public static final String PASSWORD = "";
//获取连接对象
public static Connection getConnection(){
Connection conn = null;
ClassforName(DRIVER_CLASS);
conn = DriverManagergetConnection(URL,USERNAME,PASSWORD);
return conn;
}
public static void closeAll(ResultSet rs,Statement stmt,Connection conn){
try{
if(rs!=null){
rsclose();
rs = null;
}
if(stmt!=null){
stmtclose();
stmt = null;
}
if(conn!=null){
connclose();
conn=null;
}
}
}
}
public class DBOperator{
public int executeUpdate(String sql,Object[] params){
int rows = 0;
Connection connn = ConnectionManagergetConnection();
PreparedStatement pstmt = connprepareStatement(sql);
if(params!=null){
for(int i=0;i<paramslength;i++){
pstmtsetObject(i+1,params[i]);//下标从1开始
}
}
rows = pstmtexecuteUpdate();
ConnectionManagercloseAll(null,pstmt,conn);
return rows;
}
public ResultSet executeQuery(String sql,Object[] params){
Connetion conn = ConnectionManagergetConnection();
if(params!=null){
for(int i= 0;i<paramslength;i++){
pstmtsetObject(i+1,params(i));
}
}
rs=pstmtexecuteQuery();
ConnectionManagercloseAll(rs,pstmt,conn);
return rs;
}
}
/
statement连接数据库
/
public class TestOperatorGrade{
private static void updateGrade(int id,String name,String description){
ClassforName();//注册驱动
Connection conn = DirverManagergetConnection("","","");
Statement stmt = conncreateStament();
String sql = "UPDATE grades set name = '"+name+"',description='"+description+"'WHere id="+id;
int rows = stmtexecuteUpdate(sql);
}
}
这是java 程序的代码
java连接数据库的代码位于MVC中的M(模型层)中,主要负责与数据库打交道。
本人把我以前写的代码加上注释给你看看希望对你有帮助。
publicclassUserInfoDAO{
//验证登陆名/密码sql语句
//private-----这个sql语句只在本类内部使用,没有必要public
//static-----sql语句仅仅一份就足够了
//final-----sql语句一般在运行时不变,final修饰的变量相当于常量
//常量名所有字母大写
privatestaticfinalStringSQL_CHECK_USERINFO=
"SELECTLOGINNAME,USERNAME,PASSWORD,AGE,ADDRESSFROMUSERINFOWHERELOGINNAME=ANDPASSWORD=";
publicUserInfoDAO(){
}
/
验证登陆名/密码方法
@paramuUserInfo
@returnboolean
/
publicbooleancheckUser(UserInfou){
booleanb=false;//验证是否成功的标识
Connectionconn=null;//数据库连接的引用
pstmt=null;//引用
ResultSetrs=null;//结果集引用
//调用的方法,得到数据库里连接实例
conn=();
try{
//通过Connection的()方法构建实例,参数为sql语句
pstmt=conn(SQL_CHECK_USERINFO);
//为sql语句中的赋值,注意序号从1开始
pstmtsetString(1,u());
pstmtsetString(2,ugetPassword());
//执行查询得到结果集
rs=pstmt();
//在结果集中循环,如果结果集中有记录意味着验证成功
b=rsnext();//标识置为true
while(rsnext()){
b=true;//标识置为true
}
}catch(ex){
Systemoutprintln(exgetMessage());
}finally{
//注意:一定在finally中释放数据库资源
cleanUP(rs,pstmt,conn);
}
returnb;
}
privatevoidcleanUP(ResultSetrs,pstmt,Connectionconn){
try{
if(rs!=null){
rsclose();
}
if(pstmt!=null){
pstmtclose();
}
if(conn!=null){
connclose();
}
}catch(ex){
Systemoutprintln(exgetMessage());
}
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)