Código fuente de consulta de biblioteca IP
Paquete com.song.struts.MySQL;
Importar javax.swing.jcomponent;
Importar Java.SQL.*;
Importar Java .util *;
//Importar com .borland .SQL *; Cadena privada Nombre de usuario = " raíz
Cadena privada PWD= "raíz";
URL de cadena privada
Cn privada;
Declaración privada stmt
Conjunto de resultados privado rs = null
Público mySqlDao(){
Prueba {
class forname (" org . gjt . mm . Controlador MySQL ");
}
catch(Java . lang . classnotfoundexception e){
system . err . println(" mydb( )org . gjt . mm . Controlador MySQL: " e . getmessage());
}
Captura (Excepción e) {
e.printstacktrace ();
}
}
/////////////////// ///// //////
///Volver a la conexión mysql, conexión
////////////////// /// /////////
Conexión pública Connect(string dbname, string ip){
Prueba {
String hostip = ip
Propiedades myP = new Properties();
myP.setProperty("useUnicode", "true");
myp set property( "codificación de caracteres", " GB 2312");
URL = "JDBC:MySQL://"hostip":3306/"dbname"? usuario = "nombre de usuario" & contraseña = " PWD " ";
if (cn!=null){
cn . close();
}
cn = administrador de controladores . getconnection(URL, myP);
stmt = cn crear declaración(ResultSet. TYPE_SCROLL_INSENSITIVE, ResultSet.
CONCUR _updatable);
System.out.println("conexión a la base de datos exitosa");
Devolver cn;
}
Captura (Excepción e){
system . err println(" db connect err " e . getmessage()); >
}
///////////////////////////////////// p>
///Cerrar la conexión
////////////////////////////////// /
Cierre de vacío público(){
Pruebe{
if (stmt!=null){
stmt close().
}
Si (cn!=null){
cn close();
}
<. p >System.err.println("La base de datos se cerró correctamente");}
Captura (Excepción e){
system err . db close err " e . getmessage());
}
}
//////////////// / /////////////////////////////
//Se utiliza para consultar registros y seleccionar declaraciones.
//Parámetro: instrucción SQL
//Retorno: objeto del conjunto de resultados
//////////////// ////////////////////////////
Selección de ejecución del conjunto de resultados público (cadena sql) {
Pruebe {
stmt = cn . crear declaración(ResultSet. TYPE_SCROLL_SENSITIVE, ResultSet. CONCUR_updatable);
RS = stmt . >Devuelve RS;
}
catch(SQLException ex) {
system err . println(" db . ejecutar consulta: " ex . getmessage(). );
Devolver nulo
}
}
///////////// /// ////////////////////////////////
//Se utiliza para agregar o? Actualizar, insertar, eliminar y otras operaciones de registro,
//Parámetro de entrada: declaración sql
//Retorno: verdadero, falso
///// //////////////////////////////////////////
público boolean enableUpdate(String sql) {
boolean bupdate = false
Prueba {
stmt = cn create Statement(ResultSet. TYPE_SCROLL_SENSITIVE, ResultSet.
CONCUR_updatable);
int rowCount = stmt ejecutar actualización(SQL);
if (rowCount!=0)
bupdate = true
bupdate = true
p>
}
catch(SQLException ex) {
system err . " ex . getmessage());
}
Volver a actualizar
}
///////// ///////////// /////////////////////////
//Para estructura de tabla operaciones, como crear, soltar, modificar, etc.
//Parámetro de entrada: declaración sql
//Retorno: verdadero, falso
/////////////// //////////////////////////////////
ejecución booleana pública (cadena sql) {
boolean bupdate = false
Pruebe {
stmt = cn . create Statement(ResultSet. TYPE_SCROLL_SENSITIVE, ResultSet. CONCUR_updatable
System. out.print("SQL para operaciones de tabla es: | | " SQL " | | ");
stmt ejecutar actualización(SQL);
bupdate = true
.}
catch(SQLException ex) {
system . err . println(" db . ejecutar tabla：" ex . getmessage()
> p>
}
Volver a actualizar
}
////////////////// // //////
//Devuelve información de la base de datos.
////////////////////////////
Declaración pública getLWPAIDSstatement(){
Intente {
Devolver cn.createStatement(ResultSet. TYPE_SCROLL_SENSITIVE, ResultSet.
CONCUR _ actualizable);
}
catch(java.sql.SQLException e){
system err . e. getmessage());
Devolver nulo
}
}
Metadatos de bases de datos públicas getLWPAIDMetaData(){
Pruebe {
return cn . get metadata();
}
catch(java.sql.SQLException e){
system . err . println(" getisp metadata(): " e . getmessage()
Devolver nulo
}
}
Public static void main(String args[]){
mySqlDao a = new mySqlDao();
a.Connect("mydb", " localhost ");
int b =-100;
ResultSet RS = a . ejecutar select(" select max(bill _ id)from t _ bill limit 1 "); p>Pruebe {
while(rs.next()){
system out . println(" está en "); getint(1);
}
}catch(Excepción e){
e . printstacktrace(); p>
sistema. println(b);
//Java fecha fecha = nueva fecha Java(); out . println(date . tostring());
//a ejecutar table("insertar en valores t_user(100,' 123',' 1345 ')");
p>//a . ejecutar tabla(" actualizar t _ conjunto de usuario insertar _ fecha = ' " fecha . tostring() " 'donde usuario _ id = 100 "); ;
sistema . print(new pub()como C2 unicode("! "));
}
}