Beiträge von Mogly1

package Mysql; // anpassen

import java.sql.*;

public class mysql {
    
    private static String url = "jdbc:mysql://Ip/DatenBank"; //Serverip und Datenbank auswählen
    private static String user = "root";
    private static String pass = "password";
    private static Connection con = null;

    public static void main(String[] args){
        
    }
    
    public static void close()// schließt die Mysql Conenction con und setzt sie wieder auf null (falls es nicht geht, gibt es ein Mysql fehler aus)
    {
        try {
            if(!con.isClosed())
            {
                con.close();
                con = null;
                System.out.println("Database closed");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static PreparedStatement prepareStatement(String s)
    {
        try {
            return con.prepareStatement(s);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
    }
    
    public static Statement createStatement()
    {
        try {
            return con.createStatement();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
    }
    
    public static boolean open() //Öffnet eine verbindun, falls keiner existiert. dafür nutzen fir die Conenction con variable.
    {
        if(con != null)return true;
        try {
            con = DriverManager.getConnection(url, user, pass);
            System.out.println("Database connected");
        }
        catch (SQLException e) {
            System.out.println(e.getMessage());
            return false;
        }
        return true;
    }
}

package Mysql;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class programm {

    public static void main(String[] args){
        auftragLaden();
    }
    
    public static void auftragLaden()
    {
        if(!mysql.open())return;
        try
        {
            Statement stm = mysql.createStatement();
            String query = "SELECT * FROM Tabelle";
            
            ResultSet rs = stm.executeQuery(query);
            while(rs.next()){
                //rs.getInt("SpaltenName aus der Tabelle"), achte gleich auf die werte ob Int, String, boolean
                System.out.println(rs.getInt("ID") + " " +
                        rs.getString("Name")); //Bsp.
            }
            
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static void auftragSpeichern()
    {
        if(!mysql.open())return;
        try
        {
            String query = "UPDATE Tabelle SET Thema = ? WHERE ID = ?";  
            PreparedStatement ps = mysql.prepareStatement(query);
            
            // ps.setString(a,b) a = welches Fragezeichen aus der query fängt bei 1. b = der wert für das Fragezeichen geht auch setString und co.
            ps.setInt(1, 99);
            ps.setInt(2, 4); //beispiele
            
            ps.executeUpdate();
            System.out.println("Mysql Updated");
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
    public static void auftragErstellen()
    {
        if(!mysql.open())return;
        try
        {
            String query = "INSERT INTO Tabelle (Regel, Thema) VALUES (?, ?)";  
            PreparedStatement ps = mysql.prepareStatement(query);
            
            // ps.setString(a,b) a = welches Fragezeichen aus der query fängt bei 1. b = der wert für das Fragezeichen 
            ps.setString(1, "Nicht bei Rot fahren");
            ps.setInt(2, 108); //beispiele
            
            ps.executeUpdate();
            System.out.println("Mysql Insert");
            
            mysql.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    
}

Erkärung noch evtl. weil du meintest nciht verstanden:

Verbindung aufbauen tuhen wir hiermit:

    private static String url = "jdbc:mysql://Ip/DatenBank"; //Serverip und Datenbank auswählen
    private static String user = "root";
    private static String pass = "password";
    private static Connection con = null;
    
    try {
            con = DriverManager.getConnection(url, user, pass);
            System.out.println("Database connected");
    }
    catch (SQLException e) {
            System.out.println(e.getMessage());
            return false;
    }
    
wichtig ist immer,w enn wir mit mysql fertig sind die conenction weider zuschließen.
dafür nutzen wir dann

    con.close();
    
mit 
    co.prepareStatement(query);
    
    können wir noch die ? ersetzen und somit mit unseren values füllen
    
und am ende

    con.createStatement();
    
    damit erstellen wir einfach eine feste query abfrage
    
    
    
ich habe das als Klasse ausgelagert, damit man leichtere übersicht hat und man es noch als Object anpassen kann für verschiedene Datenbanken...

using System.Text;

namespace Dini
{
    internal class Dini
    {
        static string path = @"C:\...\";//Pfad anpassen wo die datein landen sollen

        public static bool diniExists(string name)
        {
            string fileName = path + name + ".txt";
            reutrn File.Exists(fileName);
        }
        public static void diniCreate(string name)
        {
            string fileName = path + name + ".txt";
            if (File.Exists(fileName)) return;
            try
            {
                using (FileStream fs = File.Create(fileName))
                {
                    byte[] info = new UTF8Encoding(true).GetBytes("Player\n");// lässt oben als Info Palyer stehen
                    fs.Write(info, 0, info.Length);
                }
            }
            catch (Exception e)
            {
                Console.WriteLine("The deletion failed: {0}", e.Message);
            }
        }

        public static void diniRemove(string name)
        {
            string fileName = path + name + ".txt";
            if (File.Exists(fileName))
            {
                try
                {
                    File.Delete(fileName);
                }
                catch (Exception e)
                {
                    Console.WriteLine("The deletion failed: {0}", e.Message);
                }
            }
            else
            {
                Console.WriteLine("Specified file doesn't exist");
            }
        }


        public static void diniSet(string name, string key, string value)
        {
            string fileName = path + name + ".txt";
            key = key.ToLower();
            if (!File.Exists(fileName)) return;

            string[] lines = File.ReadAllLines(fileName);
            
            for(int i=1; i < lines.Length; i++)
            {
                if(lines[i].Contains(key))
                {
                    lines[i] = key + ":" + value;
                    File.WriteAllLines(fileName, lines);
                    return;
                }
            }

            using (StreamWriter sw = File.AppendText(fileName))
            {
                sw.WriteLine(key + ":" + value);
            }
            return;
        }

        public static string diniGet(string name, string key)
        {
            key = key.ToLower();
            string fileName = path + name + ".txt";
            if (!File.Exists(fileName)) return "Null";

            string[] lines = File.ReadAllLines(fileName);

            for (int i = 1; i < lines.Length; i++)
            {
                if (lines[i].Contains(key))
                {
                    int value = lines[i].IndexOf(":");
                    return lines[i].Substring(value+1);
                }
            }
            return "Null";
        }
    }
}

#define _DEFAULT_SOURCE
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <time.h>

#define NUM_THREADS   5
#define sle 0.01
#define crosses 10

clock_t start_t, end_t;
char enter[NUM_THREADS]; // init with 0
int tickets[NUM_THREADS]; // init with 0
int bridge_crosses;
int accidents;
int state[NUM_THREADS];

int lock (long tid) {
    int i, max = 0;
    enter[tid] = 1;
    for (i = 0; i < NUM_THREADS; i++) {
        if (max < tickets[i])
        {
            max = tickets[i];
        }
    }
    tickets[tid] = max + 1;
    enter[tid] = 0;
    printf("tid: %ld, my ticket is: %d\n", tid, tickets[tid]);
    for (i = 0; i < NUM_THREADS; i++) {
        if (i != tid) {
            while (enter[i])
                ;
            while((tickets[i] != 0) && ((tickets[tid] > tickets[i]) || ((tickets[tid] == tickets[i])&&(tid > i))))
            {
                printf("thread waiting\n");//ohne das geht es nicht O.o
            }
        }
    } 
    return 0;
}

int unlock (long tid) {
 printf("tid: %ld, unlocked \n", tid);
 tickets[tid] = 0;
 return 0;
}


void *bridge_scenario (void *threadid)
{
  long tid;
  tid = (long) threadid;
  printf ("Hello World! It's me, thread #%ld !\n", tid);
  while (bridge_crosses < crosses) {
    if (state[tid] == 0 || state[tid] == 3) {
        
        // try to access critical section
        lock(tid);
        printf("tid: %ld doing stuff\n", tid);
        state[tid] += 1;
        for (int i = 0; i < NUM_THREADS; i++) {
            if (i == tid) {
                continue;
            }
            if (state[i] == 1 || state[i] == 4){
                accidents += 1;
                //printf("KOLLISION\n");
                break;
            }
        }
        sleep(sle);
        state[tid] += 1;
        unlock(tid);
        bridge_crosses += 1;
    }
    else if (state[tid] == 2) {
        //sleep(sle);
        state[tid] += 1;
    }
    else {
        //sleep(sle);
        state[tid] = 0;
    }
  }

  pthread_exit (NULL);
}

int main()
{
  start_t = clock();    
  pthread_t threads[NUM_THREADS];
  int rc;
  long t;

  // init data
  bridge_crosses = 0;
  accidents = 0;

  for (t = 0; t < NUM_THREADS; t++) {
    state[t] = 0;
     printf ("In main: creating thread %ld\n", t);
     rc = pthread_create(&threads[t], NULL, bridge_scenario, (void *)t);
     if (rc) {
        printf ("ERROR; return code from pthread_create () is %d\n", rc);
        exit (-1);
     }
  }

  // joining threads
  for (t = 0; t < NUM_THREADS; t++) {
    pthread_join(threads[t], NULL);
  }

  // output
  end_t = clock();
  double total_t = (double)(end_t - start_t) / CLOCKS_PER_SEC;
  printf ("bridge crosses: %d\n accidents: %d \n time: %f \n", bridge_crosses, accidents, total_t);

  /* Last thing that main() should do */
  pthread_exit (NULL);
  return 0;
}

CC = gcc
CFLAGS = -std=c11 -Wall -Wextra -pedantic -O2 -g -pthread
#CPPFLAGS = -MMD -MF $*.d #activate only if you want extra output as .d files
# TODO: edit BIN with your target binary (e.g. exercise01)
BIN  = uebung02
OBJS = $(BIN).o

all: $(BIN) 

# uncomment this if you want object files
#$(BIN): $(OBJS)

run: $(BIN)
    ./$(BIN)

# define test cases here
test1: $(BIN)
    ./$(BIN) 5
test2: $(BIN)
    ./$(BIN) 10

# run all testcases
test: test1 test2

clean:
    @$(RM) -v $(BIN) *.o *.d

.PHONY: clean all

//das in der Methode nutzen
getCarOwnerName(carid,cInfo[carid][besitzer]);//Nun ist in GetPVarString der owner name
Name = GetPVarString(carid,"Owner");
//----

forward getCarOwnerName(carid,ownerId);
public getCarOwnerName(carid,ownerId)
{
        new query[256];
        mysql_format(Handle,query,sizeof(query),"SELECT Username From user WHERE ID='%d'",ownerId);
        mysql_tquery(Handle,query,"OnOwnerName","dd",carid,ownerId);
        return 1;
}

forward OnOwnerName(carid,ownerId);
public OnOwnerName(carid,ownerId)
{
    new num_fields,num_rows;
    cache_get_data(num_rows,num_fields);
    if(num_rows==0)
    {
        SetPVarString(carid,"Owner","Error");
    }
    else
    {
        new name[MAX_PLAYER_NAME];
        cache_get_field_content(0,"Username",name);
        SetPVarString(carid,"Owner",name);
    }
    return 1;
}