Código fuente de grabación de eventos
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){
Pruebe {
caracteres String hostip = ip
Propiedades myP = new Properties();
myP.setProperty("useUnicode", "true");
propiedad myp.set (" 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>
}
////////////////////////////////////< / p>
///Cerrar la conexión
///////////////////////////////// // /
Cerrar vacío público(){
Intentar{
if (stmt!=null){
stmt cerrar. () ;
}
Si (cn!=null){
cn close();
}
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 . >Devolver 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 mesa operaciones de estructura, como crear, soltar, modificar, etc.
//Parámetro de entrada: instrucció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 update(SQL);
bupdate = true
}
catch(SQLException ex) {
system . err . println(" db . ejecutar tabla:"+ex . getmessage()
}
Volver a la actualización
}
////////////////// /// /////
//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 ");
Pruebe {
while(rs.next()){
system out . RS . getint(1);
}
}catch(Excepción e){
e .
sistema . println(b);
//Java fecha fecha = nueva fecha Java(); system . out . println(date . tostring());
//a ejecutar table("insertar en valores t_user(100,' 123',' 1345 ')");
//a . ejecutar tabla(" actualizar t _ conjunto de usuario insertar _ fecha = ' "+ fecha . tostring()+" 'donde usuario _ id = 100 "); ();
sistema . print(new pub()como C2 unicode("! "));
}
}